我的ENV: flink-1.4,kafka-0.10,cdh-5.11.1
我在yarn上运行flink,我确信我的程序是正常的,但我就是看不到监视器指标,如下图所示:

这是Job DAG:

发布于 2018-03-19 16:08:51
这些统计数据一开始可能有点误导。它们对应于单个操作符链。他们说这个链发送/接收了多少字节/记录。因为您的整个DAG只由一个链组成,所以您会在其中看到零。
如果您想要查看底层操作员的指标,请转到Task metrics ->,从下拉列表中选择您想要查看的指标。
https://stackoverflow.com/questions/49354735
复制相似问题