Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2491 Checkpointing only works if all operators/tasks are still running
  3. FLINK-21085

Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks

    XMLWordPrintableJSON

    Details

      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.

        Attachments

          Issue Links

          links to

          Web Link GitHub Pull Request #14820

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                gaoyunhaii Yun Gao
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated: