Avoid infinite and unecessary loop when CN RPC processors are killed/…

…interrupted by OS (#12584)
apache · May 24, 2024 · fad6553 · fad6553
1 parent f60694b
commit fad6553
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterManager.java
@@ -63,6 +63,8 @@ public String getClusterIdWithRetry(long maxWaitTime) {
         Thread.sleep(100);
       } catch (InterruptedException e) {
         Thread.currentThread().interrupt();
+        LOGGER.warn("Unexpected interruption during waiting for get cluster id.");
+        break;
       }
     }
     return clusterInfo.getClusterId();

diff --git a/...fignode/src/main/java/org/apache/iotdb/confignode/manager/consensus/ConsensusManager.java b/...fignode/src/main/java/org/apache/iotdb/confignode/manager/consensus/ConsensusManager.java
@@ -408,6 +408,7 @@ public TSStatus confirmLeader() {
           } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
             LOGGER.warn("Unexpected interruption during waiting for configNode leader ready.");
+            break;
           }
         }
         result.setMessage(