Flink 仪表板吞吐量不加起来答案

【问题标题】：Flink Dashboard Throughput doesn't add upFlink 仪表板吞吐量不加起来
【发布时间】：2021-01-10 15:17:02
【问题描述】：

我有两个运算符，一个源和一个映射。地图的传入吞吐量停留在 6K 消息/秒以上，而消息计数在 20 秒内达到整个流的大小（~ 350K）（参见持续时间）。 350000/20 意味着我的吞吐量至少为 17500 而不是 flink 建议的 6000！这是怎么回事？

如图：

开始时间 = 13:10:29

所有消息都已在 = 13:10:46（不到 20 秒）之前阅读

【问题讨论】：

【解决方案1】：

我检查了 flink 库代码，似乎 numRecordsOutPerSecond 统计信息（以及其他类似的统计信息）在窗口上运行。这意味着它们显示平均吞吐量，但最后 X 秒。不是整个执行的平均吞吐量

【讨论】：