Pengzna commented on code in PR #12355:
URL: https://github.com/apache/iotdb/pull/12355#discussion_r1616752946
##########
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeExtractorConstant.java:
##########
@@ -91,6 +91,13 @@ public class PipeExtractorConstant {
public static final String SOURCE_WATERMARK_INTERVAL_KEY =
"source.watermark-interval-ms";
public static final long EXTRACTOR_WATERMARK_INTERVAL_DEFAULT_VALUE = -1; //
-1 means no watermark
+ ///////////////////// pipe consensus /////////////////////
+ public static final String EXTRACTOR_CONSENSUS_GROUP_ID_KEY =
"extractor.consensus.group-id";
+ public static final String EXTRACTOR_CONSENSUS_SENDER_DATANODE_ID_KEY =
+ "extractor.consensus.sender-dn-id";
+ public static final String EXTRACTOR_CONSENSUS_RECEIVER_DATANODE_ID_KEY =
Review Comment:
it seems no use. Can @yschengzi please give some point?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
