[BugFix] Fix online optimize progress is not update in time (#50253)

Signed-off-by: meegoo <[email protected]>
StarRocks · Aug 26, 2024 · 43fb771 · 43fb771
1 parent 8f9c666
commit 43fb771
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/alter/OnlineOptimizeJobV2.java b/fe/fe-core/src/main/java/com/starrocks/alter/OnlineOptimizeJobV2.java
@@ -333,6 +333,9 @@ protected void runRunningJob() throws AlterCancelException {
             if (rewriteTask.getOptimizeTaskState() == Constants.TaskRunState.FAILED
                         || rewriteTask.getOptimizeTaskState() == Constants.TaskRunState.SUCCESS) {
                 progress += 100 / rewriteTasks.size();
+                if (this.progress < progress) {
+                    this.progress = progress;
+                }
                 continue;
             }