Reputation: 11
My ENV: flink-1.4,kafka-0.10,cdh-5.11.1
I'm running flink on yarn, Im sure my program is OK, but I just cannot see the monitor metrics, As shown in the picture below :
AND here is the Job DAG:
Upvotes: 0
Views: 166
Reputation: 3422
Those statistics might be a bit misleading at first. They correspond to a single operator chain. They say how many bytes/records were sent/received by this chain. Because your whole DAG consists of only a single chain you see zeros in there.
If you want to see metrics for underlying operators go to Task Metrics -> from the drop down list choose a metric you want to see.
Upvotes: 1