Update DataNodeShutdownHook.java

Author: Caideyipi

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

@@ -127,9 +127,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 {
@@ -139,6 +146,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