Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task FLINK-4191

FLINK-3211 Expose shard information in KinesisDeserializationSchema

Robert Metzger Robert Metzger Major Resolved Fixed  
Sub-task FLINK-4085

FLINK-3211 Set Kinesis Consumer Agent to Flink

Robert Metzger Robert Metzger Major Resolved Fixed  
Sub-task FLINK-4080

FLINK-3211 Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Critical Resolved Fixed  
Sub-task FLINK-4033

FLINK-3211 Missing Scala example snippets for the Kinesis Connector documentation

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Minor Resolved Fixed  
Sub-task FLINK-4020

FLINK-3211 Remove shard list querying from Kinesis consumer constructor

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Major Resolved Fixed  
Sub-task FLINK-4019

FLINK-3211 Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Major Resolved Fixed  
Sub-task FLINK-4018

FLINK-3211 Configurable idle time between getRecords requests to Kinesis shards

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Major Resolved Fixed  
Sub-task FLINK-3923

FLINK-3211 Unify configuration conventions of the Kinesis producer to the same as the consumer

Abdullah Ozturk Robert Metzger Major Resolved Fixed  
Sub-task FLINK-3231

FLINK-3211 Handle Kinesis-side resharding in Kinesis streaming consumer

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Major Closed Fixed  
Sub-task FLINK-3230

FLINK-3211 Kinesis streaming producer

Robert Metzger Tzu-Li (Gordon) Tai Major Resolved Fixed  
Sub-task FLINK-3229

FLINK-3211 Kinesis streaming consumer with integration of Flink's checkpointing mechanics

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Major Resolved Fixed  

Cancel