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

The SourceOperatorStreamTask should implement cancelTask() and finishTask()

    XMLWordPrintableJSON

    Details

      Description

      The SourceOperatorStreamTask does not implement cancelTask and finishTask at this point. This causes resource leak on job cancellation of finish.

      Currently there are three cases that a Job may exit.

      1. Canceled - cancelTask() method will be called to close the SourceOperator.
      2. Stopped with a savepoint - finishTask() method will be called to close the SourceOperator.
      3. Runs to the EndOfInput -  the SourceOperator is closed in StreamTask.afterInvoke().

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                becket_qin Jiangjie Qin
                Reporter:
                becket_qin Jiangjie Qin
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: