[To dev/1.3] Stabilize air-gap batch compression IT (#18492)

Author: Caideyipi

integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSinkCompressionIT.java

@@ -137,6 +137,8 @@ private void doTest(
           TestUtils.executeNonQueryWithRetry(senderEnv, "flush");
           TestUtils.executeNonQueryWithRetry(receiverEnv, "flush");
         };
+    final Consumer<String> senderOnlyFailure =
+        o -> TestUtils.executeNonQueryWithRetry(senderEnv, "flush");
 
     try (final SyncConfigNodeIServiceClient client =
         (SyncConfigNodeIServiceClient) senderEnv.getLeaderConfigNodeConnection()) {
@@ -198,7 +200,7 @@ private void doTest(
           "select count(*) from root.**",
           "count(root.db.d1.s1),",
           Collections.singleton("8,"),
-          handleFailure);
+          senderOnlyFailure);
     }
   }