|
|
|
FLINK-12675
|
FLINK-10886
Event time synchronization in Kafka consumer
|
Unassigned
|
Thomas Weise
|
|
Resolved |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-10921
|
FLINK-10886
Prioritize shard consumers in Kinesis Consumer by event time
|
Thomas Weise
|
Thomas Weise
|
|
Resolved |
Implemented
|
|
|
|
|
|
|
|
FLINK-10888
|
FLINK-10886
Expose new global watermark RPC to sources
|
Jamie Grier
|
Jamie Grier
|
|
Resolved |
Implemented
|
|
|
|
|
|
|
|
FLINK-10887
|
FLINK-10886
Add source watermark tracking to the JobMaster
|
Jamie Grier
|
Jamie Grier
|
|
Resolved |
Implemented
|
|
|
|
|