Update fe/fe-core/src/main/java/com/starrocks/transaction/OlapTableTx…

…nLogApplier.java Co-authored-by: wyb <[email protected]> Signed-off-by: zhanghe <[email protected]>
StarRocks · Dec 16, 2024 · 2138b9c · 2138b9c
1 parent 843f6c3
commit 2138b9c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/transaction/OlapTableTxnLogApplier.java b/fe/fe-core/src/main/java/com/starrocks/transaction/OlapTableTxnLogApplier.java
@@ -124,8 +124,7 @@ public void applyVisibleLog(TransactionState txnState, TableCommitInfo commitInf
                         long lastFailedVersion = replica.getLastFailedVersion();
                         long newVersion = version;
                         long lastSucessVersion = replica.getLastSuccessVersion();
-                        if (!txnState.tabletCommitInfosContainsReplica(tablet.getId(), replica.getBackendId(),
-                                replica.getState())
+                        if (transactionState.checkReplicaNeedSkip(tablet, replica, partitionCommitInfo)
                                 || errorReplicaIds.contains(replica.getId())) {
                             // There are 2 cases that we can't update version to visible version and need to
                             // set lastFailedVersion.