JingsongLi opened a new pull request, #163: URL: https://github.com/apache/flink-table-store/pull/163
In FileStoreCommitImpl, currently, it uses `rename` to support atomic commit. But this is not work for object store like S3. We can use RecoverableWriter to support atomic commit for object store. We can introduce `AtomicFileWriter`: - Use rename if createRecoverableWriter is not supported or the filesystem is FILE_SYSTEM - Use RecoverableWriter if FileSystem supports createRecoverableWriter -- 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
