[FLINK-6311] NPE in FlinkKinesisConsumer if source was closed before run

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.2.2, 1.3.0
• Component/s: Connectors / Kinesis
• Assignee: zhangminglei
• Reporter: Tzu-Li (Gordon) Tai
• Created: 17/Apr/17 05:06
• Updated: 20/Apr/17 23:23
• Resolved: 20/Apr/17 23:23

Description

This was reported by an user: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-errors-out-and-job-fails-IOException-from-CollectSink-open-td12606.html

The shutdownFetcher method of KinesisDataFetcher is not protected against the condition when the source was closed before it started running. Both mainThread and shardConsumersExecutor should have null checks.

Issue Links

• links to: GitHub Pull Request #3738