jt2594838 commented on a change in pull request #3191:
URL: https://github.com/apache/iotdb/pull/3191#discussion_r640236954
##########
File path:
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatThread.java
##########
@@ -70,4 +70,14 @@ void sendHeartbeatAsync(Node node) {
// erase the sent partition table so it will not be sent in the next
heartbeat
request.unsetPartitionTableBytes();
}
+
+ @Override
+ void startElection() {
+ // if (localMetaMember.getThisNode().metaPort != 9003 &&
+ // localMetaMember.getThisNode().metaPort != 9005) {
+ // return;
+ // }
+ super.startElection();
+ localMetaMember.getAppendLogThreadPool().submit(() ->
localMetaMember.processEmptyContentLog());
Review comment:
Understood, but this is also reachable for non-leader nodes, better to
put it where the election is won.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
