We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 59f911b commit 101ec75Copy full SHA for 101ec75
1 file changed
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
@@ -203,7 +203,7 @@ public void testLegacyConnector() throws Exception {
203
final String receiverIp = receiverDataNode.getIp();
204
final int receiverPort = receiverDataNode.getPort();
205
206
- try (final Connection connection = EnvFactory.getEnv().getConnection();
+ try (final Connection connection = senderEnv.getConnection();
207
final Statement statement = connection.createStatement()) {
208
statement.execute(
209
String.format(
0 commit comments