(iotdb) branch dev/1.3 updated: Pipe: Fixed the compilation failure of dev/1.3

[justinchen]

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

justinchen 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 6cc148ae10b Pipe: Fixed the compilation failure of dev/1.3
6cc148ae10b is described below

commit 6cc148ae10b356310ae97325435c107ba8f1d14a
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Jul 23 17:14:41 2025 +0800

    Pipe: Fixed the compilation failure of dev/1.3
---
 .../org/apache/iotdb/pipe/it/autocreate/IoTDBPipeExtractorIT.java  | 7 -------
 1 file changed, 7 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeExtractorIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeExtractorIT.java
index bb5d4bb1459..4b33de0a31c 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeExtractorIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeExtractorIT.java
@@ -762,13 +762,6 @@ public class IoTDBPipeExtractorIT extends 
AbstractPipeDualAutoIT {
 
     final String receiverIp = receiverDataNode.getIp();
     final int receiverPort = receiverDataNode.getPort();
-    final Consumer<String> handleFailure =
-        o -> {
-          TestUtils.executeNonQueryWithRetry(senderEnv, "flush");
-          TestUtils.executeNonQueryWithRetry(receiverEnv, "flush");
-        };
-
-    boolean insertResult;
 
     try (final SyncConfigNodeIServiceClient client =
         (SyncConfigNodeIServiceClient) 
senderEnv.getLeaderConfigNodeConnection()) {