This is currently expected behavior. We do not measure incoming records for sources, and outgoing records for sinks as we can't do this in a generalized fashion.

See FLINK-7286.

On 19.03.2018 02:37, 热爱大发挥 wrote:
I run flink on yarn , Im sure my program is OK, but I just cannot see the monitor metrics, 
my ENV: flink-1.4,kafka-0.10,cdh-5.11.1