From bbfed507da6e0c7ef64b262e950856c686ae1b99 Mon Sep 17 00:00:00 2001 From: Siyang Tang <82279870+TangSiyang2001@users.noreply.github.com> Date: Thu, 7 Nov 2024 14:07:24 +0800 Subject: [PATCH] [fix](schema-change) Make sc job state updated after the table state is changed (#42670) (#43186) pick: #42670 --- .../java/org/apache/doris/alter/SchemaChangeJobV2.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java b/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java index 2c3004c25b..f925752436 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java +++ b/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java @@ -591,14 +591,16 @@ public class SchemaChangeJobV2 extends AlterJobV2 { } pruneMeta(); - this.jobState = JobState.FINISHED; - this.finishedTimeMs = System.currentTimeMillis(); - Env.getCurrentEnv().getEditLog().logAlterJob(this); LOG.info("schema change job finished: {}", jobId); changeTableState(dbId, tableId, OlapTableState.NORMAL); LOG.info("set table's state to NORMAL, table id: {}, job id: {}", tableId, jobId); + + this.jobState = JobState.FINISHED; + this.finishedTimeMs = System.currentTimeMillis(); + Env.getCurrentEnv().getEditLog().logAlterJob(this); + // Drop table column stats after schema change finished. Env.getCurrentEnv().getAnalysisManager().dropStats(tbl); }