为什么flink dashboard不显示从源接收或写入接收器的记录数?

hfsqlsce  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(532)

flink Jmeter 板很棒,它显示了正在运行的作业的许多细节。不过,我注意到的一点是,作业的源和汇将显示接收的记录和发送的记录 0 分别。
现在我知道他们仍然在工作之外收发记录,但是 0 容易让人迷惑。为什么选择这样呢?或者是一种让它不成为现实的方式 0 ?
特别是对于接收器,如果序列化模式未能序列化消息(捕获并记录错误而不是导致作业失败),则无法看到接收器实际输出的数字来反映这一点。你总是看到 0 假设一切顺利。

vcudknz3

vcudknz31#

原因是我们不能以一种普遍的方式来测量,而必须在每个源/汇中分别实现测量,因为我们还没有找到时间。另一个问题是,这必须在用户定义的函数中完成,但是相关的度量还不能从那里访问。
看到了吗https://issues.apache.org/jira/browse/flink-7286.

相关问题