This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 29aad95ff84 Pipe: Fixed the legacy sink IT (#17164)
29aad95ff84 is described below
commit 29aad95ff84a4d22f74acf38377aa2289e930de6
Author: Caideyipi <[email protected]>
AuthorDate: Thu Feb 5 10:38:29 2026 +0800
Pipe: Fixed the legacy sink IT (#17164)
---
.../iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
index 035d5052cb7..141788b8085 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
@@ -214,7 +214,7 @@ public class IoTDBPipeDataSinkIT extends
AbstractPipeDualTreeModelAutoIT {
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(
