This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch rc/1.3.7 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 101ec754c9b863ef7af43af25c0677ce27f04dea 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(
