在实时集成作业中,作业运行异常报错信息包含关键字“Ddl type 'ALTER_ADD_COLUMN' is configured with policy 'EXCEPTION”怎么办?
问题描述
在实时集成任务中,源端进行了增加列DDL变更,作业运行异常,报错关键字“Ddl type 'ALTER_ADD_COLUMN' is configured with policy 'EXCEPTION'”。
报错信息详情:
Caused by: org.apache.inlong.sort.protocol.ddl.exception.DdlHandleException: migration.10000400: Encountered a DDL error, please resolve the DDL manually. Error stack:
Ddl type 'ALTER_ADD_COLUMN' is configured with policy 'EXCEPTION'
. DDL sql: alter table llch96.rds_source_tbl_961 add column ddl_add_text varchar(20) default 'default_value'
at org.apache.inlong.sort.protocol.ddl.utils.DdlPolicyUtils.processWithDdlPolicy(DdlPolicyUtils.java:34) ~[blob_p-b7cce999877870001e778eb40e09ff21b660374d-f69acd8b299a8cc367cf97aa891f53e2:?]
... 17 more
2025-07-28 19:56:29,753 WARN org.apache.flink.runtime.taskmanager.Task [] - Call stack:
at java.lang.Thread.getStackTrace(Thread.java:1564)
at org.apache.flink.runtime.taskmanager.Task.transitionState(Task.java:1139)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:801)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:573)
at java.lang.Thread.run(Thread.java:750)
原因分析
实时写Hudi支持在线同步源端新增的列,用户需要配置作业时开启“DDL配置”配置中的“新增列”配置项为“正常处理”。
解决方案
暂停作业,开启“DDL配置”配置中的“新增列”配置项为“正常处理”,提交作业后点恢复即可。