[flink-table-store] branch master updated: [hotfix] AtomicFileWriter should not throw exception when RecoverableWriter is not work

[lz...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new e0e4680d [hotfix] AtomicFileWriter should not throw exception when RecoverableWriter is not work
e0e4680d is described below

commit e0e4680dca54336e7eab06c0a6b0ad999f27065e
Author: JingsongLi <lz...@aliyun.com>
AuthorDate: Wed Nov 16 15:01:28 2022 +0800

    [hotfix] AtomicFileWriter should not throw exception when RecoverableWriter is not work
---
 .../java/org/apache/flink/table/store/file/utils/AtomicFileWriter.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/AtomicFileWriter.java b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/AtomicFileWriter.java
index 4e3467fd..fc4f6c38 100644
--- a/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/AtomicFileWriter.java
+++ b/flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/AtomicFileWriter.java
@@ -42,7 +42,7 @@ public interface AtomicFileWriter {
         RecoverableWriter recoverableWriter = null;
         try {
             recoverableWriter = fs.createRecoverableWriter();
-        } catch (UnsupportedOperationException ignore) {
+        } catch (Throwable ignore) {
         }
 
         if (recoverableWriter == null || fs.getKind() == FileSystemKind.FILE_SYSTEM) {