better logger

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java

@@ -619,6 +619,8 @@ public void persistAllProgressIndex2ConfigNode() {
               IoTDBDescriptor.getInstance().getConfig().getDataNodeId(), resp);
       if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != result.getCode()) {
         LOGGER.warn("Failed to persist progress index to configNode, status: {}", result);
+      } else {
+        LOGGER.info("Successfully persisted all pipe's info to configNode.");
       }
     } catch (final Exception e) {
       LOGGER.warn(e.getMessage());

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNodeShutdownHook.java

@@ -96,9 +96,16 @@ public void run() {
     if (PipeDataNodeAgent.task().getPipeCount() != 0) {
       for (Map.Entry<String, PipeDataNodeRemainingEventAndTimeOperator> entry :
           PipeDataNodeSinglePipeMetrics.getInstance().remainingEventAndTimeOperatorMap.entrySet()) {
-        while (entry.getValue().getRemainingNonHeartbeatEvents() > 0) {
+        boolean timeout = false;
+        while (true) {
+          if (entry.getValue().getRemainingNonHeartbeatEvents() > 0) {
+            logger.info(
+                "Successfully waited for pipe {} to finish.", entry.getValue().getPipeName());
+            break;
+          }
           if (System.currentTimeMillis() - startTime
               > PipeConfig.getInstance().getPipeMaxWaitFinishTime()) {
+            timeout = true;
             break;
           }
           try {
@@ -108,6 +115,10 @@ public void run() {
             logger.info("Interrupted when waiting for pipe to finish");
           }
         }
+        if (timeout) {
+          logger.info("Timed out when waiting for pipes to finish, will break");
+          break;
+        }
       }
     }
     // Persist progress index before shutdown to accurate recovery after restart