(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Fixed the legacy sink IT (#17164) (#17165)

[ju...@apache.org]

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 c8b11452d66 [To dev/1.3] Pipe: Fixed the legacy sink IT (#17164) (#17165)
c8b11452d66 is described below

commit c8b11452d66f0fea6d3c6e795e7a0b52c0c10cea
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Thu Feb 5 10:41:56 2026 +0800

    [To dev/1.3] Pipe: Fixed the legacy sink IT (#17164) (#17165)
---
 .../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(