THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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.
...