pnowojski commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-774937518
Could you rephrase what do you mean by: > If a task received RPC trigger, it indicates it must have processed all the EndOfInputEvent and might only have some pending CheckpointBarrier to process. In this case the task could bookkeep the received RPC checkpoint triggers, and after all the EndOfPartition is processed, it could then trigger all the bookkept checkpoints. ? ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
