FlinkFlink Heartbeat of TaskManager with id timed out.
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink Heartbeat of TaskManager with id timed out.相关的知识,希望对你有一定的参考价值。
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载。
1.场景1
1.1 概述
我用flink 读取稍微大点的表 就会报Heartbeat of TaskManager with id XXXX timed out
这种错误 有大佬知道怎么解决嘛
异常直接原因是 TaskManager 心跳超时,进一步原因可能有:
- 进程已退出,可能自身发生错误,或者受到 YARN RM 或 NM 上抢占机制影响,需要进一步追查 TaskManager 日志或 YARN RM/NM 日志;
- 进程仍在运行,集群网络问题造成失联,连接超时会自行退出,JobManager 在该异常后会 Failover 自行恢复(重新申请资源并启动新的 TaskManager);
- 进程 GC 时间过长,可能是内存泄露或内存资源配置不合理造成,需根据日志或分析内存进一步定位具体原因。
以上是关于FlinkFlink Heartbeat of TaskManager with id timed out.的主要内容,如果未能解决你的问题,请参考以下文章
FlinkFLink 使用 RocksDB 报错 hadoop not have enough number of replicas
Flink - The heartbeat of TaskManager with id container timed out 分析与 Heartbeat 简介
FlinkFLink Akka Current version of akka xxx but akka-http requires version xxx
Flinkflink-1.12 通过 -t 指定模式后无法指定yarn参数
FlinkFLink SQL TableException: Table sink doesn‘t support consuming update changes which is