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 81157e91b3b2..3705f92bd546 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 @@ -135,8 +135,7 @@ protected void doCommit(TableMetadata base, TableMetadata metadata) { io().deleteFile(newMetadataLocation); } } catch (RuntimeException e) { - LOG.error("Fail to cleanup metadata file at {}", newMetadataLocation, e); - throw e; + LOG.error("Failed to cleanup metadata file at {}", newMetadataLocation, e); } } } diff --git a/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java b/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java index a9132bbdb623..c45dbccb3974 100644 --- a/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java +++ b/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java @@ -247,8 +247,7 @@ void cleanupMetadataAndUnlock(CommitStatus commitStatus, String metadataLocation io().deleteFile(metadataLocation); } } catch (RuntimeException e) { - LOG.error("Fail to cleanup metadata file at {}", metadataLocation, e); - throw e; + LOG.error("Failed to cleanup metadata file at {}", metadataLocation, e); } finally { if (lockManager != null) { lockManager.release(commitLockEntityId, metadataLocation); diff --git a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java index bc9053c59f2e..c937aada0ee1 100644 --- a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java +++ b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java @@ -578,8 +578,7 @@ private void cleanupMetadataAndUnlock(CommitStatus commitStatus, String metadata io().deleteFile(metadataLocation); } } catch (RuntimeException e) { - LOG.error("Fail to cleanup metadata file at {}", metadataLocation, e); - throw e; + LOG.error("Failed to cleanup metadata file at {}", metadataLocation, e); } finally { unlock(lockId); tableLevelMutex.unlock();