[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278533#comment-16278533
]
ASF GitHub Bot commented on FLINK-4812:
---------------------------------------
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5125
[WIP][FLINK-4812][metrics] Expose currentLowWatermark for all operators
This is a revised WIP version of #5100.
## What is the purpose of the change
With this PR all operators expose the current input/output watermark
through the metric system.
This PR is not complete; it is missing tests and documentation, but I want
to gather feedback on the solution first.
## Brief change log
* input watermark metrics for the head operator are measure in the stream
input processor classes
* the remaining watermark metrics are measure in the Output classes
* operators can define whether input/output watermarks should override the
other (for example, sources override the input watermark with the output
watermark).
* watermark metrics are setup for the most part in the `OperatorChain`,
with the exception of 2 additional metrics for two input operators
(currentInput[1|2]Watermark)
@aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 4812c
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5125.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #5125
----
commit 9ab939d0cf5d0ea7f5f6feb2a5ad7e5b3030bbaf
Author: zentol <ches...@apache.org>
Date: 2017-12-05T13:20:29Z
[FLINK-4812][metrics] Expose currentLowWatermark for all operators
----
> 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)
