Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Implemented
-
None
Description
Shard consumer threads currently emit records directly. In order to align shards by event time, decouple shard consumer threads and emitter with a queue, as described in [1].
Attachments
Issue Links
- is blocked by
-
FLINK-5697 Add per-shard watermarks for FlinkKinesisConsumer
-
- Resolved
-
- links to