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 <lzljs3620...@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) {