tsreaper opened a new pull request #12: URL: https://github.com/apache/flink-table-store/pull/12
This PR introduces an atomic commit transaction for file store. 1. Before calling `FileStoreCommitImpl#commit`, user should first call `FileStoreCommitImpl#filterCommitted` to make sure this commit is not done before. 2. Before committing, it will first check for conflicts by checking if all files to be removed currently exists. 3. After that it use the external `FileStoreCommitImpl#lock` (if provided) or the atomic rename of the file system to ensure atomicity. 4. If commit fails due to conflicts or exception it tries its best to clean up and aborts. 5. If atomic rename fails it tries again after reading the latest snapshot from step 2. -- 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
