Deadlock in Subtask in the FlinkKinesisConsumer

Hi I wanted to bring awareness to this Jira describing a deadlock state we've experienced for a single subtask in the FlinkKinesisConsumer. This occurs when we've reached the following conditions in the subtask: - reached the max lookahead so th

[jira] [Created] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

seth saperstein created FLINK-29099: --- Summary: Deadlock for Single Subtask in Kinesis Consumer Key: FLINK-29099 URL: https://issues.apache.org/jira/browse/FLINK-29099 Project: Flink Issue