开发者社区大数据与机器学习实时计算 Flink 正文

flink 消费kafka 偶尔出现单个分区lag延迟特别大分区数据是均匀的，不存在倾斜，

flink 消费kafka 偶尔出现单个分区lag延迟特别大分区数据是均匀的，不存在倾斜，这种情况怎么回事？

展开

收起

云上静思 2022-08-12 18:33:08 2088 版权

1 条回答

写回答

取消提交回答

云墩墩

看下Execption，是不是有没有异常或者脏数据

此答案来自钉钉群“【2】Apache Flink China 社区”

2022-08-12 21:59:06

赞同展开评论

问答分类：

消息中间件 Kafka 流计算实时计算 Flink版云消息队列 Kafka 版

问答标签：

实时计算 Flink版数据实时计算 Flink版kafka 云消息队列 Kafka 版flink 云消息队列 Kafka 版数据云消息队列 Kafka 版分区

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

Flink延迟一般多久呀？

Flink捕获的时候延迟大吗？

在Flink CDC中，你这个把这个参数去掉那延迟就很大你们是怎么解决的呢？

143

Flink消费是有延迟的但是不知道是投递延迟还是消费延迟的？

Flink 在正常处理下的延迟大约是多少？

162

flink-cdc是不是对mysql比较友好，mysql会有很大的延迟吗？

100

在Flink CDC中因为Mongo中数据存在删除操作，这种怎么处理呀？

158

在Flink为什么拉取的数据太少反而会造成业务延迟变高啊？

对于Flink CDC，从mysql到doris数据同步，同步位点信息存在哪里？

在Flink CDC中任务重启，从checkpoint恢复数据，binlog也存在，就是读取不到如何

142

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。