Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6311

NPE in FlinkKinesisConsumer if source was closed before run

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.2.2, 1.3.0
    • Component/s: Kinesis Connector
    • Labels:
      None

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mingleizhang zhangminglei
                Reporter:
                tzulitai Tzu-Li (Gordon) Tai
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: