Pengzna commented on code in PR #15569:
URL: https://github.com/apache/iotdb/pull/15569#discussion_r2103976666
##########
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java:
##########
@@ -1393,8 +1393,9 @@ public void closeSelf(ConsensusPipeName
consensusPipeName) {
* although events can arrive receiver in a random sequence.
*/
private class RequestExecutor {
- private static final String THIS_NODE = "this node";
- private static final String PIPE_TASK = "pipe task";
+ private static final String THIS_NODE = "sender dn restarts before this
event was sent here";
+ private static final String PIPE_TASK = "pipe task restarts before this
event was sent here";
+ private static final String REPLICATE_INDEX = "replicate index is out
dated";
Review Comment:
fixed
--
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]
