database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](MethodName) fix method issue #34178

Browse Source
This commit is contained in:
GoGoWen
2024-04-27 23:15:37 +08:00
committed by yiguolei
parent 2b5bac3b60
commit 818022cadf
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/clone/TabletSchedCtx.java
View File

@ -775,7 +775,7 @@ public class TabletSchedCtx implements Comparable<TabletSchedCtx> {
boolean allCatchup = true;
for (Replica replica : furtherRepairs) {
if (checkFurthurRepairFinish(replica, visibleVersion)) {
if (checkFurtherRepairFinish(replica, visibleVersion)) {
replica.setNeedFurtherRepair(false);
replica.setFurtherRepairWatermarkTxnTd(-1);
} else {
@ -858,7 +858,7 @@ public class TabletSchedCtx implements Comparable<TabletSchedCtx> {
setDest(chosenReplica.getBackendId(), chosenReplica.getPathHash());
}
private boolean checkFurthurRepairFinish(Replica replica, long version) {
private boolean checkFurtherRepairFinish(Replica replica, long version) {
if (replica.getVersion() < version || replica.getLastFailedVersion() > 0) {
return false;
}
@ -1209,7 +1209,7 @@ public class TabletSchedCtx implements Comparable<TabletSchedCtx> {
// change from prepare to committed or visible, this replica will be fall behind and be removed
// in REDUNDANT detection.
//
boolean isCatchup = checkFurthurRepairFinish(replica, partition.getVisibleVersion());
boolean isCatchup = checkFurtherRepairFinish(replica, partition.getVisibleVersion());
replica.incrFurtherRepairCount();
if (isCatchup || replica.getLeftFurtherRepairCount() <= 0) {
replica.setNeedFurtherRepair(false);