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.
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