(iotdb) branch rc/1.3.1 updated: fix compile issue

[haonan]

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch rc/1.3.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rc/1.3.1 by this push:
     new fa911cb6d44 fix compile issue
fa911cb6d44 is described below

commit fa911cb6d44da02c0d4b7282de9eed351d0e3fcf
Author: HTHou <hhao...@outlook.com>
AuthorDate: Fri Apr 19 16:05:11 2024 +0800

    fix compile issue
---
 .../org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java    | 16 +---------------
 1 file changed, 1 insertion(+), 15 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java
index 09df263e108..42cdc2ebf4c 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java
@@ -338,11 +338,6 @@ public class IoTDBPipeProtocolIT extends 
AbstractPipeDualIT {
     
doTestUseNodeUrls(BuiltinPipePlugin.IOTDB_THRIFT_ASYNC_CONNECTOR.getPipePluginName());
   }
 
-  @Test
-  public void testAirGapConnectorUseNodeUrls() throws Exception {
-    
doTestUseNodeUrls(BuiltinPipePlugin.IOTDB_AIR_GAP_CONNECTOR.getPipePluginName());
-  }
-
   private void doTestUseNodeUrls(String connectorName) throws Exception {
     senderEnv
         .getConfig()
@@ -370,16 +365,7 @@ public class IoTDBPipeProtocolIT extends 
AbstractPipeDualIT {
 
     StringBuilder nodeUrlsBuilder = new StringBuilder();
     for (DataNodeWrapper wrapper : receiverEnv.getDataNodeWrapperList()) {
-      if 
(connectorName.equals(BuiltinPipePlugin.IOTDB_AIR_GAP_CONNECTOR.getPipePluginName()))
 {
-        // use default port for convenience
-        nodeUrlsBuilder
-            .append(wrapper.getIp())
-            .append(":")
-            .append(wrapper.getPipeAirGapReceiverPort())
-            .append(",");
-      } else {
-        nodeUrlsBuilder.append(wrapper.getIpAndPortString()).append(",");
-      }
+      nodeUrlsBuilder.append(wrapper.getIpAndPortString()).append(",");
     }
 
     try (SyncConfigNodeIServiceClient client =