【问题标题】:How to understand the percentage of backpressure in Flink?如何理解 Flink 中背压的百分比?
【发布时间】:2022-09-27 16:21:15
【问题描述】:

我试图理解 Flink 中背压百分比的含义。

我认为它指的是可用缓冲区的大小。但我不明白它的确切含义。

例如,它有 80% 的背压,那么它的精确含义是什么?我知道 Flink 中背压的一般概念,但即使我阅读了相关文章,也无法理解解释背压值的百分比。

谢谢

    标签: apache-flink


    【解决方案1】:

    从 Flink 1.13 开始,算子可以处于以下三种状态之一:

    • 闲置的, 表示没有要处理的数据
    • 背压,表示它被阻塞,等待输出缓冲区
    • 忙碌的,这意味着它既不是空闲的也不是背压的

    如果操作员有 80% 的背压,这意味着操作员在过去一秒内被背压了 800 毫秒。

    【讨论】:

    • 谢谢您的回答。为了在底层理解它,我在哪里可以看到在 Flink 模块中计算的那些输出缓冲区和百分比?
    猜你喜欢
    • 1970-01-01
    • 2023-02-04
    • 2017-12-28
    • 1970-01-01
    • 2016-02-13
    • 1970-01-01
    • 2015-04-15
    • 1970-01-01
    • 2019-06-20
    相关资源
    最近更新 更多