BUAAserein commented on code in PR #11614:
URL: https://github.com/apache/iotdb/pull/11614#discussion_r1407183916
##########
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java:
##########
@@ -344,7 +352,7 @@ public void updateSafelyDeletedSearchIndex() {
// update safely deleted search index to delete outdated info,
// indicating that insert nodes whose search index are before this value
can be deleted
// safely
Review Comment:
Done.
##########
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java:
##########
@@ -233,6 +237,10 @@ public long getCurrentSyncIndex() {
return controller.getCurrentIndex();
}
+ public long getLastFlushedSyncIndex() {
Review Comment:
Done.
##########
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCServiceProcessor.java:
##########
@@ -244,7 +244,7 @@ public void waitSyncLogComplete(
return;
}
long searchIndex = impl.getSearchIndex();
- long safeIndex = impl.getCurrentSafelyDeletedSearchIndex();
+ long safeIndex = impl.getMinFlushedIndex();
Review Comment:
Done.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
