Do you know what part of the code happens to block off your watermark? Maybe a method that is overridden in AbstractStreamOperator in your code?
On Sat, Aug 10, 2019 at 4:06 AM Roshan Naik <[email protected]> wrote: > Have streaming use cases where it is useful & easier to generate the > watermark in the Source (via ctx.emitWatermark() ) and assign timestamps > in a downstream custom operator which calls output.collect(new > StreamRecord<T>(msg, time)). > When doing so, I see that the watermark reaches the downstream operator, > but does not flow past it and consequently further downstream windows > remain open. (I am using Flink 1.6). > -roshan > >
