This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/TableModelGrammar in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6e709c0048ffa4ef5256a08e1d29c69ef8e41f7b Author: Peng Junzhi <[email protected]> AuthorDate: Thu Jul 25 22:04:27 2024 -0500 avoid start pipe by PipeConsensus (#13031) (cherry picked from commit ed9204e56b08d1353f67853b914975ceabea52eb) --- .../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(
