flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zentol <...@git.apache.org>
Subject [GitHub] flink issue #5092: [FLINK-4812][metrics] Expose currentLowWatermark for all ...
Date Wed, 29 Nov 2017 11:08:18 GMT
Github user zentol commented on the issue:

    If we separate the watermark metric into in- and output metrics we can simplify the the
whole thing for sources. We can just intercept emitted watermarks in the `Output` like we
do for `numRecordsOut`, and re-use the same gauge as the input for sources/assigners.


View raw message