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)?---
