Allow all iceberg exceptions to be fault tolerant

apache · Aug 22, 2022 · 867d496 · 867d496
1 parent d4510fd
commit 867d496
Showing 1 changed file with 0 additions and 2 deletions.
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
@@ -870,8 +870,6 @@ public void flush(String dbName, String tableName) throws IOException {
       } else {
         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);
     } catch (Exception e) {
       throw new IOException(String.format("Fail to flush table %s %s", dbName, tableName), e);
     } finally {