文档首页/ 数据治理中心 DataArts Studio/ 常见问题/ 数据集成(实时作业)/ 在实时集成作业中,作业运行异常报错信息包含关键字“Ddl type 'ALTER_ADD_COLUMN' is configured with policy 'EXCEPTION”怎么办?
更新时间:2025-11-03 GMT+08:00
分享

在实时集成作业中,作业运行异常报错信息包含关键字“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配置”配置中的“新增列”配置项为“正常处理”,提交作业后点恢复即可。

相关文档