[FLINK-4714] Set task state to RUNNING after state has been restored

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.2.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Wei-Che Wei
• Reporter: Till Rohrmann
• Created: 29/Sep/16 17:27
• Updated: 19/Jan/21 16:36
• Resolved: 19/Jan/21 16:36

Description

The task state is set to RUNNING as soon as the Task is executed. That, however, happens before the state of the StreamTask invokable has been restored. As a result, the CheckpointCoordinator starts to trigger checkpoints even though the StreamTask is not ready.

In order to avoid aborting checkpoints and properly start it, we should switch the task state to RUNNING after the state has been restored.

Issue Links

• blocks: FLINK-4815 Automatic fallback to earlier checkpoints when checkpoint restore fails
• is superceded by: FLINK-17012 Expose stage of task initialization
• relates to: FLINK-6918 Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest
• relates to: FLINK-18983 Job doesn't changed to failed if close function has blocked
• links to: GitHub Pull Request #3474
• links to: GitHub Pull Request #3474