From 2f2f8ee73e1940dbca02c413e4ecc91889a7c8b1 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Thu, 20 Jun 2024 11:41:25 +0800 Subject: [PATCH] Update ConsensusPipeManager.java --- .../consensus/pipe/consensuspipe/ConsensusPipeManager.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeManager.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeManager.java index a6402a8610d2..540c3530da0e 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeManager.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeManager.java @@ -34,6 +34,7 @@ import static org.apache.iotdb.commons.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_PARALLEL_TASKS_KEY; import static org.apache.iotdb.commons.pipe.config.constant.PipeConnectorConstant.CONNECTOR_IOTDB_PORT_KEY; import static org.apache.iotdb.commons.pipe.config.constant.PipeConnectorConstant.CONNECTOR_KEY; +import static org.apache.iotdb.commons.pipe.config.constant.PipeConnectorConstant.CONNECTOR_REALTIME_FIRST_KEY; import static org.apache.iotdb.commons.pipe.config.constant.PipeExtractorConstant.EXTRACTOR_CONSENSUS_GROUP_ID_KEY; import static org.apache.iotdb.commons.pipe.config.constant.PipeExtractorConstant.EXTRACTOR_CONSENSUS_RECEIVER_DATANODE_ID_KEY; import static org.apache.iotdb.commons.pipe.config.constant.PipeExtractorConstant.EXTRACTOR_CONSENSUS_SENDER_DATANODE_ID_KEY; @@ -82,6 +83,7 @@ public void createConsensusPipe(Peer senderPeer, Peer receiverPeer) throws Excep .put(CONNECTOR_CONSENSUS_PIPE_NAME, consensusPipeName.toString()) .put(CONNECTOR_IOTDB_IP_KEY, receiverPeer.getEndpoint().ip) .put(CONNECTOR_IOTDB_PORT_KEY, String.valueOf(receiverPeer.getEndpoint().port)) + .put(CONNECTOR_REALTIME_FIRST_KEY, String.valueOf(false)) .put(CONNECTOR_IOTDB_PARALLEL_TASKS_KEY, String.valueOf(1)) .build()); }