This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch jira6266 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 38fd5fa4e82a2fc913f13e965658e8971d00efcc Author: OneSizeFitQuorum <[email protected]> AuthorDate: Mon Dec 18 12:06:16 2023 +0800 Fix replica = 1 Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../iotdb/consensus/iot/logdispatcher/LogDispatcher.java | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java index 47da07944f0..00d136695f4 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java @@ -160,12 +160,15 @@ public class LogDispatcher { } public void checkAndFlushIndex() { - threads.forEach( - thread -> { - IndexController controller = thread.getController(); - controller.update(controller.getCurrentIndex(), true); - }); - reader.setSafelyDeletedSearchIndex(impl.getMinFlushedSyncIndex()); + if (!threads.isEmpty()) { + threads.forEach( + thread -> { + IndexController controller = thread.getController(); + controller.update(controller.getCurrentIndex(), true); + }); + // do not set SafelyDeletedSearchIndex as it is Long.MAX_VALUE when replica is 1 + reader.setSafelyDeletedSearchIndex(impl.getMinFlushedSyncIndex()); + } } public void offer(IndexedConsensusRequest request) {
