Throw TrinoException when Iceberg commit fails

trinodb · Sep 6, 2024 · b3e4cb9 · b3e4cb9
1 parent 21198fa
commit b3e4cb9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java
@@ -1624,7 +1624,7 @@ private static void commitUpdateAndTransaction(SnapshotUpdate<?> update, Connect
             commit(update, session);
             commitTransaction(transaction, operation);
         }
-        catch (UncheckedIOException e) {
+        catch (UncheckedIOException | ValidationException e) {
             throw new TrinoException(ICEBERG_COMMIT_ERROR, format("Failed to commit during %s: %s", operation, firstNonNull(e.getMessage(), e)), e);
         }
     }