[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278865#comment-16278865
]
ASF GitHub Bot commented on FLINK-4812:
---------------------------------------
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5125
There are a few reason for that:
1) It keeps the `Outputs` immutable. We need all metrics to be available up
front before creating the output, but since the OperatorIOMetricGroup is
created in `StreamOperator#setup` (which requires the Output) this just doesn't
work. We could create the OperatorMetricGroup before calling setup, but that
would mean a) moving even more things into the OperatorChain (and that thing is
loaded _as is_) b) requiring a way to pass said group to the operator (or
living with a duplicate call to `TaskMetricGroup#addOperator`).
2) It's hard to support having the same watermark for in/output" with
pre-registered metrics, as these would by design be independent.
> 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)
