Tzu-Li (Gordon) Tai created FLINK-6311: ------------------------------------------
Summary: NPE in FlinkKinesisConsumer if source was closed before run Key: FLINK-6311 URL: https://issues.apache.org/jira/browse/FLINK-6311 Project: Flink Issue Type: Bug Components: Kinesis Connector Reporter: Tzu-Li (Gordon) Tai 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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)