caidashi commented on issue #10371:
URL: https://github.com/apache/seatunnel/issues/10371#issuecomment-3775704697
Thanks for your reply. The DDL might be the one below.
** 2026-01-20 20:41:09,108 WARN [i.d.c.m.MySqlDatabaseSchema ]
[blc-17.18.80.60:3306] - Ignoring unparseable DDL statement 'ALTER TABLE
`fdc_jiangxi`.`spot_transaction_intra_prov_day_ahead_clearing`
CHANGE COLUMN `plan_run_date` `run_date` datetime NOT NULL COMMENT
'计划执行日期' FIRST': io.debezium.text.ParsingException: Trying to change column
plan_run_date in fdc_jiangxi.spot_transaction_intra_prov_day_ahead_clearing
table, which does not exist. Query: CHANGE COLUMN `plan_run_date` `run_date`
datetime NOT NULL COMMENT '计划执行日期' FIRST
2026-01-20 20:41:09,127 INFO [ySqlStreamingChangeEventSource]
[debezium-reader-0] - Keepalive thread is running
2026-01-20 20:41:09,438 INFO [e.s.t.SeaTunnelSourceCollector]
[BlockingWorker-TaskGroupLocation{jobId=1065916572402450433, pipelineId=1,
taskGroupId=2}] - mark schema-change-before checkpoint signal.
2026-01-20 20:41:09,538 INFO [e.s.t.SeaTunnelSourceCollector]
[BlockingWorker-TaskGroupLocation{jobId=1065916572402450433, pipelineId=1,
taskGroupId=2}] - capture schema-change-before checkpoint signal.
2026-01-20 20:41:09,538 INFO [o.a.s.e.s.t.SeaTunnelTask ]
[BlockingWorker-TaskGroupLocation{jobId=1065916572402450433, pipelineId=1,
taskGroupId=2}] - trigger schema-change-before checkpoint.
jobID[1065916572402450433],
taskLocation[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1065916572402450433,
pipelineId=1, taskGroupId=2}, taskID=1000200000000, index=0}]
2026-01-20 20:41:09,538 INFO [.s.e.s.c.CheckpointCoordinator]
[hz.main.generic-operation.thread-11] - stop trigger
general-checkpoint(1@1065916572402450433) because schema change in progress.
2026-01-20 20:41:09,538 INFO [.s.e.s.c.CheckpointCoordinator]
[hz.main.generic-operation.thread-11] - schedule schema-change-before
checkpoint(1@1065916572402450433).
2026-01-20 20:41:09,539 INFO [.s.e.s.c.CheckpointCoordinator]
[checkpoint-coordinator-1/1065916572402450433] - skip schedule trigger
checkpoint because checkpoint type is SCHEMA_CHANGE_BEFORE_POINT_TYPE
2026-01-20 20:41:09,539 INFO [.s.e.s.t.f.SourceFlowLifeCycle]
[BlockingWorker-TaskGroupLocation{jobId=1065916572402450433, pipelineId=1,
taskGroupId=2}] - triggered schema-change-before checkpoint, stopping collect
data
2026-01-20 20:41:09,539 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-7] - wait checkpoint completed: 462
2026-01-20 20:41:09,540 INFO [.s.e.s.c.CheckpointCoordinator]
[hz.main.generic-operation.thread-20] - Completed close
task[1000300000001](1/1065916572402450433)
2026-01-20 20:41:09,540 INFO [.s.e.s.c.CheckpointCoordinator]
[hz.main.generic-operation.thread-21] - Completed close
task[1000300010001](1/1065916572402450433)
2026-01-20 20:41:09,540 INFO [.s.e.s.t.f.SourceFlowLifeCycle]
[hz.main.seaTunnel.task.thread-10] - lock checkpoint[462] waiting for
complete..., phase: [SCHEMA-CHANGE-BEFORE]
2026-01-20 20:41:09,564 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-7] - pending
checkpoint(462/1@1065916572402450433) notify finished!
2026-01-20 20:41:09,564 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-7] - start notify checkpoint completed, job id:
1065916572402450433, pipeline id: 1, checkpoint id:462**
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
