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

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

Caideyipi pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new a43707a3518 [To dev/1.3] Stabilize air-gap batch compression IT 
(#18492)
a43707a3518 is described below

commit a43707a3518dca17cdff592af8a2a89b29c53958
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Aug 21 09:34:35 2026 +0800

    [To dev/1.3] Stabilize air-gap batch compression IT (#18492)
---
 .../apache/iotdb/pipe/it/autocreate/IoTDBPipeSinkCompressionIT.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSinkCompressionIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSinkCompressionIT.java
index 53ae05c6371..de84b765747 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSinkCompressionIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeSinkCompressionIT.java
@@ -137,6 +137,8 @@ public class IoTDBPipeSinkCompressionIT extends 
AbstractPipeDualAutoIT {
           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 @@ public class IoTDBPipeSinkCompressionIT extends 
AbstractPipeDualAutoIT {
           "select count(*) from root.**",
           "count(root.db.d1.s1),",
           Collections.singleton("8,"),
-          handleFailure);
+          senderOnlyFailure);
     }
   }