0

Flink Statefun 中一个远程函数的 backlog 怎么可能是负数？

在我目前正在处理的管道上，当集群处于压力之下并且某些功能处于背压之下时，我会经常看到这种行为。然后积压的指标有时会变成负数并留在那里。下图显示了这种现象。

背压图

根据文档，指标 numBacklog 是“待发送消息的数量”。

我只是不明白这怎么可能是负面的。有人知道吗？

4

0 回答 0