You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2025/07/23 09:14:47 UTC
(iotdb) branch dev/1.3 updated: Pipe: Fixed the compilation failure of dev/1.3
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 <87...@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()) {