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

Stop-with-savepoint is not supported by SourceOperatorStreamTask

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Critical
    • Resolution: Duplicate
    • Affects Version/s: 1.11.3, 1.12.1
    • Fix Version/s: 1.11.4, 1.12.2, 1.13.0
    • Component/s: Connectors / Common
    • Labels:
      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

              People

              • Assignee:
                Unassigned
                Reporter:
                mapohl Matthias
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: