[
https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9789:
------------------------------------
Affects Version/s: (was: 1.5.1)
1.5.0
> Watermark metrics for an operator&task shadow each other
> --------------------------------------------------------
>
> Key: FLINK-9789
> URL: https://issues.apache.org/jira/browse/FLINK-9789
> Project: Flink
> Issue Type: Bug
> Components: Metrics
> Affects Versions: 1.5.0, 1.6.0
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Blocker
>
> In FLINK-4812 we reworked the watermark metrics to be exposed for each
> operator.
> In FLINK-9467 we made further modifications to also expose these metrics
> again for tasks.
> This works by re-using the input watermark gauge for the first operator in
> the task chain, and the output watermark gauge for the last operator in the
> task chain. This means that a single metric is registered multiple times.
> Unfortunately, the metric system assumes metric objects to be unique, as can
> be seen in virtually all reporter implementations as well as the
> MetricQueryService.
> As a result the watermark metrics override each other in the reporter,
> causing only one to be reported, whichever was registered last.
> FLINK-4812 was implemented for 1.5.1, so this would be a regression.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
