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 a65612989a..f5b13a16c1 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 @@ -781,7 +781,7 @@ public class SchemaChangeJobV2 extends AlterJobV2 { } this.watershedTxnId = replayedJob.watershedTxnId; - jobState = JobState.WAITING_TXN; + jobState = JobState.PENDING; LOG.info("replay pending schema change job: {}, table id: {}", jobId, tableId); }