[ https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270933#comment-16270933 ]
ASF GitHub Bot commented on FLINK-4812: --------------------------------------- Github user zentol commented on the issue: https://github.com/apache/flink/pull/5100 You can't measure input metrics in the ChainingOutput (nicely) since for a chain A->B does B at no point have access to the output of A. We would need to have the task setup all watermark metrics and either pass them on to operators for registration or have the task register them for operators, which is just backwards. This also clashes heavily with the idea of operators deciding whether the same metric is used for input&output. > Report Watermark metrics in all operators > ----------------------------------------- > > Key: FLINK-4812 > URL: https://issues.apache.org/jira/browse/FLINK-4812 > Project: Flink > Issue Type: Improvement > Components: Metrics > Reporter: Robert Metzger > Assignee: Chesnay Schepler > Priority: Critical > Fix For: 1.5.0 > > > As reported by a user, Flink does currently not export the current low > watermark for sources > (http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/currentLowWatermark-metric-not-reported-for-all-tasks-td13770.html). > This JIRA is for adding such a metric for the sources as well. -- This message was sent by Atlassian JIRA (v6.4.14#64029)