diff --git a/paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java b/paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java index 7293dce3a4f5..5332911629ea 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java @@ -220,9 +220,6 @@ public int filterAndCommitMultiple(List committables) { } private void expire(long partitionExpireIdentifier, ExecutorService executor) { - if (expireError.get() != null) { - throw new RuntimeException(expireError.get()); - } executor.execute( () -> {