[FLINK-21323] Stop-with-savepoint is not supported by SourceOperatorStreamTask

• 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
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 08/Feb/21 20:27
• Updated: 09/Feb/21 07:17
• Resolved: 09/Feb/21 07:17

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.

Issue Links

• is related to: FLINK-21133 FLIP-27 Source does not work with synchronous savepoint