Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

It might be argued that we could wait till the Tasks C to finish processing the remaining records and report its final snapshotsTask C to finish during this checkpoint, then we could include the final snapshot directly not trigger task C in the checkpoints. However, this does not work if C is a two-phase commit sink and requires one successful checkpoint before finish, which will cause deadlock.

...