Flink 异常 - 9.The heartbeat of TaskManager with id container timed out 分析与 Heartbeat 简介
一.引言
Flink 运行任务期间报错 The heartbeat of TaskManager with id container timed out，对应任务由 Running 切换为 Failed，下面基于该问题进行排查与解决。
二.问题描述
该 Flink 任务 7x24 h 挂起，为 EventTime 模式下的有状态带 ValueState 作业，运行期间 ValueState 大小稳定，但程序会在 4-8 h 的不确定间隔下报错 The heartbeat of TaskManager with id container timed out，从而导致任务失败。
通过 yarn-streaming 任务日志可以看到任务分别在当天共重启3次：
Failed A -> 6:00 - 12:42 运行 6 h 42 min 后异常退出
Failed B -> 12:50 - 19:05 运行 6 h 15 min 后异常退出
Failed C -> 19: 10 - 22:52 运行 3 h 42 min 后异常退出
三次报错的异常栈都对应 The heartbeat of TaskManager with id container timed out，无其他显
Flink 异常 - 9.The heartbeat of TaskManager with id container timed out 分析与 Heartbeat 简介相关推荐
- 【Flink】Flink Heartbeat of TaskManager with id timed out.
文章目录 1.场景1 1.1 概述 M.参考 本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 1.场景1 1.1 概述 我用flink 读取稍微大点的表 ...
- Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id timed out.
报错信息如下: 解决办法: 将flink-conf.yaml配置文件里,将如下参数调整: heartbeat.timeout: 180000 调整后,可在管理界面上查看:
- 【flink 报错】Heartbeat of TaskManager is timed out
文章目录 报错Heartbeat of TaskManager is timed out 解决timeout时长设置大 报错Heartbeat of TaskManager is timed out ...
- 【Flink】Flink 1.10之改进的TaskManager内存模型与配置
1.概述 转载:Flink 1.10之改进的TaskManager内存模型与配置
- 【Flink-未解决】 FLink TaskManager with id is no longer reachable
文章目录 1.场景1 1.1概述 1.场景1 1.1概述 flink报错如下 org.apache.flink.runtime.jobmaster.JobMasterException: TaskMa ...
- mybatis异常：Could not find result map Java.util.Map 问题分析及解决 定位不到具体的位置的错误
mybatis异常:Could not find result map Java.util.Map 问题分析及解决 定位不到具体的位置的错误 参考文章: (1)mybatis异常:Could not ...
- 1.17.Flink 并行度详解(Parallel)、TaskManager与Slot、Operator Level、Execution Environment Level、Client Level等
1.17.Flink 并行度详解(Parallel) 1.17.1.TaskManager与Slot 1.17.2.TaskManager与Slot 1.17.3.并行度(Parallel) 1.17 ...
- 【flink】flink作业超额启动多个taskManager k8s
1.概述 flink作业按照配置应该启动4个taskManager,但是现在发现一个作业启动了十几个taskManager,jobManager只监控到3个taskManager,导致集群资源耗尽,启 ...
- 【Flink异常】Caused by: java.lang.RuntimeException: Row arity of from does not match serializers
文章目录 1. 异常详情 2. 分析原因 3. 解决办法 1. 异常详情 Caused by: java.lang.RuntimeException: Row arity of from does n ...
最新文章
- android圆角ImageView的几种实现方式
- 阅读应用的社交还能做什么？
- 持续集成接口自动化-jmeter+ant+jenkins(一)
- cv2.imread读取图像结果none_python cv2.imread 读取中文路径的图片返回为None的问题
- 数列分块入门 (1 ~ 7)
- linux关闭交互模式,linux – 关闭cp(copy)命令的交互模式(cp：overwrite？)
- 信息安全技术网络安全等级保护定级指南_行业标准 |报业网络安全等级保护定级参考指南V2.0发布，明确保护对象、定级要求...
- 高并发场景下，如何保证生产者投递到消息中间件的消息不丢失？
- 人人想健康！但，健康的，最主要因素，是什么？
- Python-程序模块化
- 图说单播，组播，广播，选播和地域播
- centos node 进程保护_NodeJs之进程守护
- 【转】12 TOP Command Examples in Linux
- python return多个值_Python函数中如何返回多个值？
- 产品从无到有的方法框架——5MVVP框架，实际是如何运作的？
- c# TcpClient 客户端断线重连类库
- 【CSS手册】css
- ZXing实现横竖屏扫描切换
- C#计算两个日期之间相差的天数
- php跟踪系统调用,使用strace命令跟踪系统调用