Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
- Each SourceReader should inform it's SourceCoordinator about the latest watermark that it has emitted so far
- SourceCoordinators should combine those watermarks and broadcast the aggregated result back to all SourceReaders
Attachments
Issue Links
- links to