This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 416eb39f868 Region Migration: Fix migration failed when there are 
unknown nodes #14293
416eb39f868 is described below

commit 416eb39f8689c2e2a35039b9d8ff42d256e82d5f
Author: Peng Junzhi <[email protected]>
AuthorDate: Tue Dec 3 18:21:36 2024 +0800

    Region Migration: Fix migration failed when there are unknown nodes #14293
---
 .../java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
 
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
index 4c2855dc412..b6e57f24eb4 100644
--- 
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
+++ 
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
@@ -521,9 +521,9 @@ public class PipeConsensusServerImpl {
         consensusPipeManager.updateConsensusPipe(
             new ConsensusPipeName(peer, targetPeer), PipeStatus.RUNNING);
       } catch (Exception e) {
+        // just warn but not throw exceptions. Because there may exist unknown 
nodes in consensus
+        // group
         LOGGER.warn("{} cannot start consensus pipe to {}", peer, targetPeer, 
e);
-        throw new ConsensusGroupModifyPeerException(
-            String.format("%s cannot start consensus pipe to %s", peer, 
targetPeer), e);
       }
     }
   }

Reply via email to