From b3e4cb9c0cfec07204dd77dbacd2169120b0c359 Mon Sep 17 00:00:00 2001 From: Slawomir Pajak Date: Fri, 6 Sep 2024 10:48:40 +0200 Subject: [PATCH] Throw TrinoException when Iceberg commit fails --- .../src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java | 2 +- 1 file changed, 1 insertion(+), 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 index 945fa942dd30e6..f7f6d0847989f2 100644 --- 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); } }