1.概述

遇到有遇到过这种情况的么？某个subtask的ck时间总是比其他的subtask久很多，检查各个subtask的消费，也没有数据倾斜，好几次ck超时都是被这个subtask拖垮的

日志开始报org.apache.kafka.common.errors.DisconnectException: null，调整request.timeout.ms后就不怎么报了。

TM的PS_Scavenge次数较大，但是3个TM都较大，唯独每次都是同一个subtask的ck时间较突出。

作业背压在kafka source端，下游数据处理也没有背压啊。

我觉得调大request.timeout，虽然kafka不超时了，但是拖得时间

【Flink】FLink checkpoint 某个 subtask 特别耗时 DisconnectException: null相关推荐

【flink】Flink常见Checkpoint超时问题排查思路
1.概述转载:Flink常见Checkpoint超时问题排查思路这里仅仅是自己学习. 在日常flink应用中,相信大家经常会遇到checkpoint超时失败这类的问题,遇到这种情况的时候仅仅只会在 ...
Flink的CheckPoint机制
这里已经是Flink的第三篇原创啦.第一篇:Flink入门讲解了Flink的基础和相关概念,第二篇:压背原理,讲解了什么是背压,在Flink背压大概的流程是怎么样的. 这篇来讲Flink另一个比较重要 ...
Flink 从 Checkpoint 中恢复数据
本文开头附:Flink 学习路线系列 ^ _ ^ 接上文:Flink笔记(十八):Flink 之 StateBackend 介绍 & 使用,本文介绍 Flink 从 Checkpoint 中恢 ...
Flink大数据实时计算系列-Flink的CheckPoint原理 Flink分布式环境下的CheckPoint原理
Flink大数据实时计算系列-Flink的CheckPoint原理 Flink分布式环境下的CheckPoint原理 Flink的CheckPoint
Flink大数据实时计算系列-Flink的checkpoint Flink的operatorState的CheckpointedFunction接口使用
Flink大数据实时计算系列-Flink的checkpoint Flink的operatorState的CheckpointedFunction接口使用目录 Flink的checkpoint 代码实 ...
Flink SQL Checkpoint 学习总结
前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到网站:https://www.captainai.net/dongkelun 前言学习总结Flink SQ ...
Flink之Checkpoint
Flink CheckPoint Checkpoint 1,checkpointConfig 2,barrier 3,如何触发checkpoint? 3.2 异步储存快照 Checkpoint Fli ...
全面讲解Flink中CheckPoint机制和Exactly Once / At Least Once应用
看完本文,你能 get 到以下知识: 介绍 CheckPoint 如何保障 Flink 任务的高可用 CheckPoint 中的状态简介如何实现全域一致的分布式快照? 什么是 barrier?什么是 ...
flink 不设置水印_从0到1学习Flink—— Flink parallelism 和 Slot 介绍
前言之所以写这个是因为前段时间自己的项目出现过这样的一个问题: 1Caused by: akka.pattern.AskTimeoutException: 2Ask timed out on [Ac ...

【Flink】FLink checkpoint 某个 subtask 特别耗时 DisconnectException: null

文章目录

1.概述

【Flink】FLink checkpoint 某个 subtask 特别耗时 DisconnectException: null相关推荐

最新文章

热门文章