From 7109613404d5a8260ba3d37201be0b8fa5668878 Mon Sep 17 00:00:00 2001 From: srlch Date: Tue, 14 Jan 2025 13:33:51 +0800 Subject: [PATCH] fix Signed-off-by: srlch --- .../src/main/java/com/starrocks/alter/AlterHandler.java | 4 +--- 1 file changed, 1 insertion(+), 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 index de4dfb8c39954..0cf0f581f41ce 100644 --- 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> 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());