You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2021/01/28 12:41:40 UTC

[GitHub] [flink] guoweiM commented on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

guoweiM commented on pull request #14740:
URL: https://github.com/apache/flink/pull/14740#issuecomment-769026789


   After some offline discussion with @gaoyunhaii we reach a consensus that we should make the algorithm(Compute “tasksToTrigger/tasksToWaitFor” ) easy to understand. In general, we agree change the algorithm from “remove impossible trigger tasks” to “compute directly the trigger tasks.”
   There are still some little open questions but Yun would fix the algorithm first then I would take another look.


----------------------------------------------------------------
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:
users@infra.apache.org