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

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

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

展开

收起

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

1 条回答

写回答

取消提交回答

云墩墩

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

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

2022-08-12 21:59:06

赞同展开评论

问答分类：

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

问答标签：

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

问答地址：

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

相关问答

实时计算 Flink版

kafka可以一个topic得多个分区在同一个broker上吗？

222

flink sink为 maxcompute时如何配置 ts字段按每个月分区？

kafka topic多个分区，同一个broker是什么情况？

dataworks读kafka写maxcompute按照这个update_time分区要怎么排查？

在Flink CDC中如下是这个参数控制保留hive 多久的分区吗？

在Flink CDC中MySQL整库同步，Kafka Pipeline 不支持指定分区吗？

117

在Flink CDC中写入kafka，这个默认是根据什么分区的，表的主键吗？

116

消息队列Kafka版Topic分区数可以减少吗

124

有大佬知道这是怎么回事么 flink读不到kafka数据

1207

请问下当flink集群重启之后 kafka消息还是重复有什么办法解决吗 kafka sink 已设

1182

大数据与机器学习

实时计算 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，提供丰富的企业级增值功能。