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

Fix possible NPE in SourceStreamTask

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0, 1.2.1
    • Component/s: Local Runtime
    • Labels:
      None

      Description

      If SourceStreamTask is cancelled before being invoked, `headOperator` is not set yet, which leads to an NPE. This is not critical but leads to noisy logs.

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user uce opened a pull request:

          https://github.com/apache/flink/pull/3606

          FLINK-6182 Fix possible NPE in SourceStreamTask

          A user ran into this and reported confusing NPEs in the logs. This could only happen if a source task is cancelled before it was invoked.

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/uce/flink 6182-npe_source

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/flink/pull/3606.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #3606


          commit b61ee091e843571e546146095842a0bf049a8910
          Author: Ufuk Celebi <uce@apache.org>
          Date: 2017-03-24T11:24:19Z

          FLINK-6182 Fix possible NPE in SourceStreamTask


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user uce opened a pull request: https://github.com/apache/flink/pull/3606 FLINK-6182 Fix possible NPE in SourceStreamTask A user ran into this and reported confusing NPEs in the logs. This could only happen if a source task is cancelled before it was invoked. You can merge this pull request into a Git repository by running: $ git pull https://github.com/uce/flink 6182-npe_source Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3606.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3606 commit b61ee091e843571e546146095842a0bf049a8910 Author: Ufuk Celebi <uce@apache.org> Date: 2017-03-24T11:24:19Z FLINK-6182 Fix possible NPE in SourceStreamTask
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user rmetzger commented on the issue:

          https://github.com/apache/flink/pull/3606

          +1 to merge

          Show
          githubbot ASF GitHub Bot added a comment - Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3606 +1 to merge
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/flink/pull/3606

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3606
          Hide
          uce Ufuk Celebi added a comment -

          Fixed in b703a24 (release-1.2), 4b19e27 (master).

          Show
          uce Ufuk Celebi added a comment - Fixed in b703a24 (release-1.2), 4b19e27 (master).

            People

            • Assignee:
              Unassigned
              Reporter:
              uce Ufuk Celebi
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development