[ 
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)

Reply via email to