0


flink cdc,standalone模式下,任务运行一段时间taskmanager挂掉

在使用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 错误。

标签: flink

本文转载自: https://blog.csdn.net/qq_41613913/article/details/135926861
版权归原作者 java咸鱼_km 所有, 如有侵权,请联系我们删除。

“flink cdc,standalone模式下,任务运行一段时间taskmanager挂掉”的评论:

还没有评论