fix

Signed-off-by: srlch <[email protected]>
StarRocks · Jan 14, 2025 · 7109613 · 7109613
1 parent ffb9b98
commit 7109613
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/alter/AlterHandler.java b/fe/fe-core/src/main/java/com/starrocks/alter/AlterHandler.java
@@ -127,9 +127,7 @@ private void clearExpireFinishedOrCancelledAlterJobsV2() {
         Iterator<Map.Entry<Long, AlterJobV2>> iterator = alterJobsV2.entrySet().iterator();
         while (iterator.hasNext()) {
             AlterJobV2 alterJobV2 = iterator.next().getValue();
-            long validDeletionTimeMs = GlobalStateMgr.getCurrentState().getClusterSnapshotMgr()
-                                                                       .getValidDeletionTimeMsByAutomatedSnapshot();
-            if (alterJobV2.isExpire() && alterJobV2.getFinishedTimeMs() < validDeletionTimeMs) {
+            if (alterJobV2.isExpire()) {
                 iterator.remove();
                 RemoveAlterJobV2OperationLog log =
                         new RemoveAlterJobV2OperationLog(alterJobV2.getJobId(), alterJobV2.getType());