(iotdb) branch master updated: avoid start pipe by PipeConsensus (#13031)

[tanxinyu]

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 ed9204e56b0 avoid start pipe by PipeConsensus (#13031)
ed9204e56b0 is described below

commit ed9204e56b08d1353f67853b914975ceabea52eb
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Thu Jul 25 22:04:27 2024 -0500

    avoid start pipe by PipeConsensus (#13031)
---
 .../java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java | 4 ++++
 1 file changed, 4 insertions(+)

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 e8a30fba388..d4b5552b7ec 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
@@ -276,6 +276,10 @@ public class PipeConsensusServerImpl {
                   consensusGroupId,
                   existedName,
                   expectedStatus);
+              if (expectedStatus.equals(PipeStatus.RUNNING)) {
+                // Do nothing. Because Pipe framework's metaSync will do that.
+                return;
+              }
               consensusPipeManager.updateConsensusPipe(existedName, 
expectedStatus);
             } catch (Exception e) {
               LOGGER.warn(