作者:吉祥话如意 | 来源:互联网 | 2023-06-12 14:27
1.背景standalone模式下,任务运行一段时间taskmanager挂掉,报错如下:Task‘Source:CustomSource-Map-Map-to:Row-M
1.背景
standalone模式下,任务运行一段时间taskmanager挂掉,报错如下:
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错误。 值为0将禁用watch dog