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

Reply via email to