[FLINK-21085] Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.14.0
• Component/s: API / DataStream, Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Yun Gao
• Reporter: Yun Gao
• Created: 22/Jan/21 03:46
• Updated: 28/Aug/21 12:18
• Resolved: 18/Jun/21 19:42

Description

For checkpoint considering finished tasks, non-source tasks might get triggered for checkpoint via RPC if they become the new "root" tasks. In this case, they would notify their CheckpointBarrierHandle for this checkpoint.

Issue Links

• links to: GitHub Pull Request #14820