|
|
|
FLINK-26164
|
FLINK-18450
Document watermark alignment
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-25983
|
FLINK-18450
Add WatermarkStrategy#withWatermarkAlignment
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-25982
|
FLINK-18450
Support idleness with watermark alignment
|
Dawid Wysakowicz
|
Piotr Nowojski
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-24441
|
FLINK-18450
Block SourceReader when watermarks are out of alignment
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-24440
|
FLINK-18450
Announce and combine latest watermarks across SourceReaders
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-24439
|
FLINK-18450
Introduce CoordinatorStore
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|