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 2026/02/05 02:41:03 UTC
(iotdb) 01/01: Pipe: Fixed the legacy sink IT (#17164)
This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch ben-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit be98e862ba7a8bede35e21d574a1dd316ed7a488
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Thu Feb 5 10:38:29 2026 +0800
Pipe: Fixed the legacy sink IT (#17164)
---
.../java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
index d59201f5605..4b58bcb4c84 100644
--- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
@@ -203,7 +203,7 @@ public class IoTDBPipeDataSinkIT extends AbstractPipeDualAutoIT {
final String receiverIp = receiverDataNode.getIp();
final int receiverPort = receiverDataNode.getPort();
- try (final Connection connection = EnvFactory.getEnv().getConnection();
+ try (final Connection connection = senderEnv.getConnection();
final Statement statement = connection.createStatement()) {
statement.execute(
String.format(