[iceberg] branch master updated: AWS: DynamoCatalog: Pass CommitFailedException up the stack without wrapping (#5299)

[dweeks]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 88b181221 AWS: DynamoCatalog: Pass CommitFailedException up the stack 
without wrapping (#5299)
88b181221 is described below

commit 88b181221f6094fddef119870714059ba19d3c18
Author: waifairer <98724840+waifai...@users.noreply.github.com>
AuthorDate: Mon Jul 18 17:16:56 2022 -0600

    AWS: DynamoCatalog: Pass CommitFailedException up the stack without 
wrapping (#5299)
---
 .../java/org/apache/iceberg/aws/dynamodb/DynamoDbTableOperations.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbTableOperations.java
 
b/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbTableOperations.java
index 3705f92bd..46c816f0c 100644
--- 
a/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbTableOperations.java
+++ 
b/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbTableOperations.java
@@ -114,6 +114,9 @@ class DynamoDbTableOperations extends 
BaseMetastoreTableOperations {
       commitStatus = CommitStatus.SUCCESS;
     } catch (ConditionalCheckFailedException e) {
       throw new CommitFailedException(e, "Cannot commit %s: concurrent update 
detected", tableName());
+    } catch (CommitFailedException e) {
+      // any explicit commit failures are passed up and out to the retry 
handler
+      throw e;
     } catch (RuntimeException persistFailure) {
       LOG.error("Confirming if commit to {} indeed failed to persist, 
attempting to reconnect and check.",
           fullTableName, persistFailure);