[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.