I use assignerTimestampsAndWatermarks after connecting two streams and it works well.
Thank you. > On 22 Aug 2019, at 3:26 PM, Jark Wu <imj...@gmail.com> wrote: > > 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 > <mailto: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
