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 574a1bf129fec5..9978870408bdb1 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 @@ -785,7 +785,7 @@ private void replayCreateJob(SchemaChangeJobV2 replayedJob) throws MetaNotFoundE } this.watershedTxnId = replayedJob.watershedTxnId; - jobState = JobState.WAITING_TXN; + jobState = JobState.PENDING; LOG.info("replay pending schema change job: {}, table id: {}", jobId, tableId); }