flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators
Date Wed, 06 Dec 2017 18:57:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16280664#comment-16280664

ASF GitHub Bot commented on FLINK-4812:

Github user zentol commented on a diff in the pull request:

    --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
    @@ -80,7 +91,10 @@ public void init() throws Exception {
     		// make sure that stream tasks report their I/O statistics
    -		inputProcessor.setMetricGroup(getEnvironment().getMetricGroup().getIOMetricGroup());
    +		inputProcessor.setupMetrics(getEnvironment().getMetricGroup().getIOMetricGroup(), input1WatermarkGauge,
    +		headOperator.getMetricGroup().gauge(MetricNames.IO_CURRENT_INPUT_1_WATERMARK, input1WatermarkGauge);
    --- End diff --
    yup. sources don't have input watermark metrics, sinks don't have output watermarks.
    Assigners would work just like any other operator. Assigners overriding the input watermark
will lead to odd observations: having a source (that emits watermarks) followed by a watermark
assigner may result in different output/input watermarks although they _should_ be identical
(source emits 2L, but assigner "receives" 4L).
    To _me_ this seems more intuitive, and it's definitely less complex :/

> 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

View raw message