问答 2023-11-01 来自:开发者社区

在Flink批量更新redis集群100%busy的,导致某个topic消费速度积压,怎么分析原因?

在Flink像这种批量更新redis集群,100%busy的,导致某一个topic的消费速度积压,怎么分析原因在哪?

问答 2023-09-13 来自:开发者社区

Flink有没有遇到过这种情况, 数据源其实是有积压的, 整体的cpu 使用率很低?

Flink有没有遇到过这种情况, 数据源其实是有积压的, 但是 subtask 之间的 cpu 负载相当不均衡, 导致 taskmanager 整体的cpu 使用率很低?

问答 2023-06-12 来自:开发者社区

近期的消费速度是如何获取的?kafka的积压消费量受flink checkpoint周期长短影响

近期的消费速度是如何获取的?kafka的积压消费量受flink checkpoint周期长短影响

文章 2022-11-27 来自:开发者社区

记一次Flink 消费Kafka数据积压排查解决

1:背景 接手了一个问题排查的工作,有个Flink任务每天不定时会出现数据积压,无论是白天还是数据量很少的夜里,且积压的数据量会越来越多,得不到缓解,只能每日在积压告警后重启,重启之后消费能力一点毛病没有,积压迅速缓解,然而,问题会周而复始的出现,无论是周末还是节假日,忍不了。2:现象 1:当积压时,最明显的是kafka积压不断升高2. Flink ProcessFunction(主要处理逻辑)....

记一次Flink 消费Kafka数据积压排查解决
问答 2020-06-30 来自:开发者社区

flink 消费kafka 出现消息积压,但是就一阵一阵的 #Flink

flink 消费kafka 出现消息积压,但是就一阵一阵的 #Flink

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

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

+关注