fix expire executor async error

tongcheng-elong · May 7, 2024 · 699386a · 699386a
1 parent e6ad289
commit 699386a
Showing 1 changed file with 0 additions and 3 deletions.
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
@@ -220,9 +220,6 @@ public int filterAndCommitMultiple(List<ManifestCommittable> committables) {
     }
 
     private void expire(long partitionExpireIdentifier, ExecutorService executor) {
-        if (expireError.get() != null) {
-            throw new RuntimeException(expireError.get());
-        }
 
         executor.execute(
                 () -> {