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 index 0dc662aa13a9..9781f77c0244 100644 --- 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/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/consensus/ConsensusManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/consensus/ConsensusManager.java index 361229f44354..6133089d5a17 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/consensus/ConsensusManager.java +++ b/iotdb-core/confignode/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(