tillrohrmann opened a new pull request #17027: URL: https://github.com/apache/flink/pull/17027
The problem was that we output the number of state entries at the time when the checkpoint is confirmed. However, at this point in time we might have already added more elements to the map. Hence, we risk reporting more elements than are actually contained in the checkpoint. The solution is to remember what the element count was when creating the checkpoint. -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
