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

Flinkflink highavailabilityservices 源码解析