diff --git a/core/src/main/java/org/apache/iceberg/TableOperations.java b/core/src/main/java/org/apache/iceberg/TableOperations.java index 6822809d799e..ddf1154171d7 100644 --- a/core/src/main/java/org/apache/iceberg/TableOperations.java +++ b/core/src/main/java/org/apache/iceberg/TableOperations.java @@ -121,9 +121,10 @@ default long newSnapshotId() { * Whether to clean up uncommitted metadata files only when a commit fails with a {@link * CleanableFailure} exception. * - *

This defaults to false: any unexpected exception will cause metadata files to be cleaned up. + *

This defaults to true: cleanup will only occur for exceptions marked as {@link + * CleanableFailure} */ default boolean requireStrictCleanup() { - return false; + return true; } } diff --git a/core/src/main/java/org/apache/iceberg/rest/RESTTableOperations.java b/core/src/main/java/org/apache/iceberg/rest/RESTTableOperations.java index 75c8bdd69fd5..0ce1afd93a79 100644 --- a/core/src/main/java/org/apache/iceberg/rest/RESTTableOperations.java +++ b/core/src/main/java/org/apache/iceberg/rest/RESTTableOperations.java @@ -240,9 +240,4 @@ public long newSnapshotId() { } }; } - - @Override - public boolean requireStrictCleanup() { - return true; - } }