LebronAl commented on a change in pull request #1112:
URL: https://github.com/apache/incubator-iotdb/pull/1112#discussion_r417716751
##########
File path:
cluster/src/main/java/org/apache/iotdb/cluster/log/catchup/LogCatchUpTask.java
##########
@@ -39,17 +43,25 @@
public class LogCatchUpTask implements Runnable {
private static final Logger logger =
LoggerFactory.getLogger(LogCatchUpTask.class);
-
- private List<Log> logs;
+ private static final int LOG_NUM_IN_BATCH = 128;
Node node;
RaftMember raftMember;
+ private List<Log> logs;
+ private boolean useBatch = false;
public LogCatchUpTask(List<Log> logs, Node node, RaftMember raftMember) {
this.logs = logs;
this.node = node;
this.raftMember = raftMember;
}
+ public LogCatchUpTask(List<Log> logs, Node node, RaftMember raftMember,
boolean useBatch) {
Review comment:
I think maybe it's better to make `useBatch` a configuration item
instead of calling it manually every time
----------------------------------------------------------------
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]
