Pipe: Reduce the frequency of printing logs when AirGapConnector connection fails (apache#14949)

Author: luoluoyuyu

iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/protocol/IoTDBAirGapConnector.java

@@ -45,7 +45,9 @@
 import java.net.SocketException;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.zip.CRC32;
 
 import static org.apache.iotdb.commons.pipe.config.constant.PipeConnectorConstant.CONNECTOR_AIR_GAP_E_LANGUAGE_ENABLE_DEFAULT_VALUE;
@@ -98,6 +100,8 @@ public String toString() {
   // The air gap connector does not use clientManager thus we put handshake type here
   protected boolean supportModsIfIsDataNodeReceiver = true;
 
+  private final Map<TEndPoint, Long> failLogTimes = new HashMap<>();
+
   @Override
   public void customize(
       final PipeParameters parameters, final PipeConnectorRuntimeConfiguration configuration)
@@ -180,12 +184,19 @@ public void handshake() throws Exception {
         socket.setKeepAlive(true);
         sockets.set(i, socket);
         LOGGER.info("Successfully connected to target server ip: {}, port: {}.", ip, port);
+        failLogTimes.remove(nodeUrls.get(i));
       } catch (final Exception e) {
-        LOGGER.warn(
-            "Failed to connect to target server ip: {}, port: {}, because: {}. Ignore it.",
-            ip,
-            port,
-            e.getMessage());
+        final TEndPoint endPoint = nodeUrls.get(i);
+        final long currentTimeMillis = System.currentTimeMillis();
+        final Long lastFailLogTime = failLogTimes.get(endPoint);
+        if (lastFailLogTime == null || currentTimeMillis - lastFailLogTime > 60000) {
+          failLogTimes.put(endPoint, currentTimeMillis);
+          LOGGER.warn(
+              "Failed to connect to target server ip: {}, port: {}, because: {}. Ignore it.",
+              ip,
+              port,
+              e.getMessage());
+        }
         continue;
       }