我的环境:flink-1.4,kafka-0.10,cdh-5.11.1我正在运行flink on yarn,我确信我的程序是正常的,但是我看不到监视器指标,如下图所示:这是工作达格:
q5iwbnjs1#
这些统计数字一开始可能有点误导。它们对应于单个操作员链。他们说这个链发送/接收了多少字节/记录。因为你的整个dag只由一条链组成,所以你可以在里面看到零。如果要查看底层操作符的度量,请从下拉列表中转到任务度量->选择要查看的度量。
1条答案
按热度按时间q5iwbnjs1#
这些统计数字一开始可能有点误导。它们对应于单个操作员链。他们说这个链发送/接收了多少字节/记录。因为你的整个dag只由一条链组成,所以你可以在里面看到零。
如果要查看底层操作符的度量,请从下拉列表中转到任务度量->选择要查看的度量。