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 <[email protected]>
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(
