Hi Sung, Watermark will be advanced only when records come in if you are using ".assignTimestampsAndWatermarks()". One way to solve this problem is you should call ".assignTimestampsAndWatermarks()" before the condition to make sure there are messages.
Best, Jark On Thu, 22 Aug 2019 at 13:52, Sung Gon Yi <skonmem...@mac.com> wrote: > Hello, > > Originally, watermark of connected stream is set by minimum of watermarks > two streams when two streams are connected. > I wrote a code to connect two streams but one of streams does not have any > message by a condition. > In this situation, watermark is never increased and processing is stuck. > > I wonder there is an option to set a watermark as latest timestamp of > either message. > > Sincerely, > Sung Gon
