Skip to content

Commit

Permalink
Update ConsensusPipeManager.java
Browse files Browse the repository at this point in the history
  • Loading branch information
Caideyipi committed Jun 20, 2024
1 parent 2f2f8ee commit 5e083f6
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -83,8 +83,8 @@ 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))
.put(CONNECTOR_REALTIME_FIRST_KEY, String.valueOf(false))
.build());
}

Expand Down

0 comments on commit 5e083f6

Please sign in to comment.