Skip to content

Add aligned checkpointing mechanism to the Keyby framework.#14

Open
victorunique wants to merge 1 commit intoververica:joe/checkpointsfrom
victorunique:checkpointing
Open

Add aligned checkpointing mechanism to the Keyby framework.#14
victorunique wants to merge 1 commit intoververica:joe/checkpointsfrom
victorunique:checkpointing

Conversation

@victorunique
Copy link
Copy Markdown
Contributor

What I did for aligned checkpoint was based on the previous KeyBy framework:

  • two sources + one operator + one sink
  • click on one source will generate a checkpoint barrier (a picture of wood log);
  • when the barrier arrives at the operator, its stream will pause and wait for the other barrier;
  • click on the other source and trigger another barrier, when the second barrier arrived at the operator, all the blocked streams resume.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant