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

可以解答一下Flink,我的source 一直是100% 是正常的吗?

有大佬可以解答一下Flink,我的source 一直是100% 是正常的吗?6a526f8c59837b40f2c264763742a88d.png

展开
收起
真的很搞笑 2024-01-23 15:48:24 105 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    是的,如果Flink的source一直显示为100%,那么这是正常的。因为这意味着Flink正在从数据源中读取数据,并且没有遇到任何问题或延迟。

    通常情况下,Flink的source会显示为100%表示它正在处理所有的数据。但是,如果你发现source的进度突然下降到50%以下,或者出现了延迟或其他异常情况,那么可能需要进一步检查和调试。

    总之,如果Flink的source一直显示为100%,那么通常是正常的,但需要密切关注其性能和状态。

    2024-01-23 21:50:14
    赞同 展开评论 打赏
  • 下游性能低下 背压了 ,此回答整理自钉群“【③群】Apache Flink China社区”

    2024-01-23 19:42:50
    赞同 展开评论 打赏
  • Apache Flink 是一个流处理和批处理的开源框架。在 Flink 的执行过程中,source 任务的完成度(或者叫作完成比例)通常反映了从外部数据源读取数据的能力。

    如果 source 任务始终显示为 100% 完成,这可能表示以下几点:

    1.数据源确实有数据:确保你的数据源确实有数据可供读取,并且 Flink 配置正确,能够从该数据源中读取数据。
    2.任务配置正确:确保 Flink 任务配置正确,特别是与数据源相关的配置。例如,如果你使用的是 Kafka,需要确保 Kafka 的地址、主题等配置正确。
    3.没有数据丢失:如果 source 任务始终显示为 100% 完成,并且没有其他异常或警告,这可能意味着 Flink 任务能够从数据源中完整地读取所有数据。
    4.注意监控其他指标:虽然 source 任务的完成度是一个重要的指标,但还有其他指标(如延迟、吞吐量等)可以提供关于任务性能的更多信息。
    5.可能的瓶颈:如果其他后续操作(例如转换或过滤)未完成或进度较低,可能是因为数据源生成数据的速度过快,超过了下游操作的处理能力。

    2024-01-23 16:59:25
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载