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

Stop-with-savepoint is not supported by SourceOperatorStreamTask

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Critical
    • Resolution: Duplicate
    • 1.11.3, 1.12.1
    • 1.11.4, 1.12.2, 1.13.0
    • Connectors / Common
    • None

    Description

      When looking into FLINK-21030 analyzing the stop-with-savepoint behavior we implemented different test jobs covering the old addSource and new fromSource methods for adding sources. The stop-with-savepoint consists of two phase:

      1. Create the savepoint
      2. Stop the source to trigger finalizing the job

      The test failing in the second phase using fromSource does not succeed. The reason for this might be that finishTask is not implemented by SourceOperatorStreamTask in contrast to SourceStreamTask which is used when calling addSource in the job definition. Hence, the job termination is never triggered.

      We might have missed this due to some naming error of JobMasterStopWithSavepointIT test that is not triggered by Maven due to the wrong suffix used in this case. The IT is failing right now. FLINK-21031 is covering the fix of JobMasterStopWithSavepointIT already.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            mapohl Matthias Pohl
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment