This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch multiLeader_out_of_order in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c33c82447689de43be797f66a0cabee6021e94ee Author: stormbroken <[email protected]> AuthorDate: Thu Jul 21 09:55:21 2022 +0800 fix array list to linked list. --- .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java index 8ab54482f1..a9329d7d4d 100644 --- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java +++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java @@ -34,13 +34,11 @@ import org.apache.iotdb.consensus.multileader.thrift.TSyncLogReq; import org.apache.iotdb.consensus.multileader.wal.ConsensusReqReader; import org.apache.iotdb.consensus.multileader.wal.GetConsensusReqReaderPlan; import org.apache.iotdb.consensus.ratis.Utils; - import org.apache.thrift.TException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.IOException; -import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedList; import java.util.List; @@ -220,7 +218,7 @@ public class LogDispatcher { public PendingBatch getBatch() { PendingBatch batch; - List<TLogBatch> logBatches = new ArrayList<>(); + List<TLogBatch> logBatches = new LinkedList<>(); long startIndex = syncStatus.getNextSendingIndex(); logger.debug("get batch. startIndex: {}", startIndex); long endIndex;
