[gobblin] branch master updated: Allow all iceberg exceptions to be fault tolerant (#3541)

[zihanli58]

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

zihanli58 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new e0d3c78d8 Allow all iceberg exceptions to be fault tolerant (#3541)
e0d3c78d8 is described below

commit e0d3c78d8d29435a7f68c4c086f605d6e0c9072c
Author: Jack Moseley <jmose...@linkedin.com>
AuthorDate: Tue Aug 23 10:40:25 2022 -0700

    Allow all iceberg exceptions to be fault tolerant (#3541)
---
 .../java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java
 
b/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java
index 643d675de..31cea7c72 100644
--- 
a/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java
+++ 
b/gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java
@@ -871,7 +871,7 @@ public class IcebergMetadataWriter implements 
MetadataWriter {
         log.info("There's no transaction initiated for the table {}", 
tid.toString());
       }
     } catch (RuntimeException e) {
-      throw new RuntimeException(String.format("Fail to flush table %s %s", 
dbName, tableName), e);
+      throw new IOException(String.format("Fail to flush table %s %s", dbName, 
tableName), e);
     } catch (Exception e) {
       throw new IOException(String.format("Fail to flush table %s %s", dbName, 
tableName), e);
     } finally {