You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by aljoscha <gi...@git.apache.org> on 2018/01/30 16:40:32 UTC

[GitHub] flink issue #5155: [FLINK-4812][metrics] Expose currentLowWatermark for all ...

Github user aljoscha commented on the issue:

    https://github.com/apache/flink/pull/5155
  
    I like this a lot now! 👍 
    
    One last comment/idea I had is this: I don't like that `StreamTask` has `getInputWatermarkGauge()` for the only reason that we need it in the `OperatorChain` to set it on the head operator. Could this not be set at the end of `OneInputStreamTask.init()` the same way it is set for `TwoInputStreamTask.init()` (where we then also would have to set the min-input-watermark)?


---