OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

coordinate watermarks between jobs?


Hi All,
  I am trying to reply events from 3 different sources and hopefully in time sequence, say Stream1, Stream2, Stream3. Since their size vary a lot, the watermarks on one stream is much faster than other streams.  Is there any way to coordinate the watermarks between different input streams. 
Thanks,
Tao