我要评论在使用flink cdc，配置任务运行，过了几天后，任务无故取消，超时，导致taskmanager挂掉，相关异常如下：
异常1：
did not react to cancelling signal interrupting; it is stuck for 30 seconds in method：org.apache.flink.connector.idbc.internal.jdbcoutputformat,flush (idbcoutoutformat.iava:215)
异常2：
task 'source: custom source -> map -> map -> to: row -> map -> sink: unnamed (1/3)’ did not react to cancelling signal for
30 seconds task did not exit gracefully within 180 + seconds.
处理该问题，需要在 flink-conf.yaml配置文件加上：
task.cancellation.timeout: 0
这个配置的含义是,超时(以毫秒为单位)，在此之后任务取消超时并导致致命的 taskmanager 错误。
发表评论