我有两个操作符，一个源和一个Map。map的传入吞吐量停留在略高于6k条消息/秒的水平，而消息计数在20秒内达到整个流的大小（约350k）（请参阅duration）。350000/20意味着我的吞吐量至少是17500，而不是flink建议的6000！这是怎么回事？如图所示：开始时间=13:10:29所有消息已由=13:10:46（小于20秒）读取
n1bvdmb61#
我检查了flink库代码，似乎numrecordsoutpersecond统计（以及其他类似的统计）是在一个窗口上运行的。这意味着它们显示的是过去x秒的平均吞吐量。它不是整个执行的平均吞吐量
1条答案
按热度按时间n1bvdmb61#
我检查了flink库代码，似乎numrecordsoutpersecond统计（以及其他类似的统计）是在一个窗口上运行的。这意味着它们显示的是过去x秒的平均吞吐量。它不是整个执行的平均吞吐量