tzulitai opened a new pull request #187: URL: https://github.com/apache/flink-statefun/pull/187
Due to how StateFun has feedback loops, with unaligned checkpoints a function dispatcher operator may receive a feedback checkpoint barrier (from other parallel subtasks that process the checkpoint barrier first) before it receives its own checkpoint barrier. This currently isn't handled. We need to further investigate how to properly support unaligned checkpointing in StateFun. For the time being, we should strictly require aligned checkpointing for StateFun apps. ---------------------------------------------------------------- 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]
