You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/11/16 02:31:02 UTC
[iotdb] branch multi_leader_duplicate_entry_debug updated: fix gap from wal bug
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch multi_leader_duplicate_entry_debug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/multi_leader_duplicate_entry_debug by this push:
new 1098035cf7 fix gap from wal bug
1098035cf7 is described below
commit 1098035cf75727eb9163ef573a39e80a5191015a
Author: OneSizeFitQuorum <ta...@apache.org>
AuthorDate: Wed Nov 16 10:30:51 2022 +0800
fix gap from wal bug
Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
.../multileader/logdispatcher/LogDispatcher.java | 15 +++++++++------
1 file changed, 9 insertions(+), 6 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 5aea9d6c7a..fe536a2220 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
@@ -389,11 +389,14 @@ public class LogDispatcher {
// Prevents gap between logs. For example, some requests are not written into the queue when
// the queue is full. In this case, requests need to be loaded from the WAL
- constructBatchFromWAL(startIndex, prev.getSearchIndex(), batches);
- if (!batches.canAccumulate()) {
- batches.buildIndex();
- logger.debug("{} : accumulated a {} from wal", impl.getThisNode().getGroupId(), batches);
- return batches;
+ if (startIndex != prev.getSearchIndex()) {
+ constructBatchFromWAL(startIndex, prev.getSearchIndex(), batches);
+ if (!batches.canAccumulate()) {
+ batches.buildIndex();
+ logger.debug(
+ "{} : accumulated a {} from wal", impl.getThisNode().getGroupId(), batches);
+ return batches;
+ }
}
if (!batches.isEmpty()
@@ -421,7 +424,7 @@ public class LogDispatcher {
// Prevents gap between logs. For example, some logs are not written into the queue when
// the queue is full. In this case, requests need to be loaded from the WAL
if (current.getSearchIndex() != prev.getSearchIndex() + 1) {
- constructBatchFromWAL(prev.getSearchIndex(), current.getSearchIndex(), batches);
+ constructBatchFromWAL(prev.getSearchIndex() + 1, current.getSearchIndex(), batches);
if (!batches.canAccumulate()) {
batches.buildIndex();
logger.debug(