Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
In FLINK-4341, we disabled transparent reshard handling in the Kinesis consumer as a short-term workaround before FLINK-4576 comes around.
This ticket tracks the progress of re-enabling it again, by implementing a LowWatermarkListener interface as described in FLINK-4576.
Attachments
Issue Links
- is blocked by
-
FLINK-5017 Introduce StreamStatus stream element to allow for temporarily idle streaming sources
- Resolved
-
FLINK-4576 Low Watermark Service in JobManager for Streaming Sources
- Closed
- links to