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 <https://issues.apache.org/jira/browse/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


Reply via email to