Flink 仪表板吞吐量不加起来
Flink Dashboard Throughput doesn't add up
我有两个运算符，一个源和一个地图。地图的传入吞吐量停留在 6K messages/s 以上，而消息计数在 20 秒内达到整个流的大小（~ 350K）（参见持续时间）。 350000/20 意味着我的吞吐量至少为 17500 而不是 flink 建议的 6000！这是怎么回事？
如图：
开始时间=13:10:29
所有消息已被阅读 = 13:10:46（不到 20 秒）
我检查了 flink 库代码，似乎 numRecordsOutPerSecond 统计数据（以及其他类似的统计数据）在 window 上运行。这意味着它们显示平均吞吐量，但显示的是最后 X 秒的吞吐量。不是整个执行的平均吞吐量
我有两个运算符，一个源和一个地图。地图的传入吞吐量停留在 6K messages/s 以上，而消息计数在 20 秒内达到整个流的大小（~ 350K）（参见持续时间）。 350000/20 意味着我的吞吐量至少为 17500 而不是 flink 建议的 6000！这是怎么回事？
如图：
开始时间=13:10:29
所有消息已被阅读 = 13:10:46（不到 20 秒）
我检查了 flink 库代码，似乎 numRecordsOutPerSecond 统计数据（以及其他类似的统计数据）在 window 上运行。这意味着它们显示平均吞吐量，但显示的是最后 X 秒的吞吐量。不是整个执行的平均吞吐量