如何理解Flink中的背压百分比？

Question

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

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

例如，它有80 %的背压，那么准确地说它意味着什么呢？我知道反压的一般概念在弗林克，但无法理解背压值的百分比，即使我读了相关的文章。

谢谢

Answer 1

由于Flink 1.13，运算符可以处于以下三种状态之一：

空闲，意思是process

• backpressured，没有数据，这意味着它被阻塞，等待输出缓冲区

• 繁忙，意味着它既不是空闲的，也不是背压的

。

如果操作者有80%的背压，这意味着操作者在过去的一秒钟中被反压了800 ms。