rkhachatryan opened a new pull request #15322: URL: https://github.com/apache/flink/pull/15322
This is an alternative implementation of #14839. It uses mailbox to pass the upload results back to store after the upload; state changes are owned by the task thread. Some edge-cases that are not handled: - truncate happens before the upload completion - new persist() call comes in before upload completion - new persist() call comes in afre upload completion but before confirmation from the JM - abort() call comes in the middle -- 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]
