a question about operatorChain.broadcastCheckpointBarrier

[Ma GuoWei]

hi,all

Why does the broadcastCheckpointBarrier need in the lock scope?


thanks a lot.


[cid:3612d450-1757-4dcb-9bb5-0d0cd8b89b1a]