[Bug] Close PartitionMarkDone to prevent potential resource leakage (a…

…pache#4357)
herefree · Oct 22, 2024 · f427fca · f427fca
1 parent 656d71e
commit f427fca
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java b/...-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java
@@ -146,6 +146,9 @@ public Map<Long, List<Committable>> groupByCheckpoint(Collection<Committable> co
     @Override
     public void close() throws Exception {
         commit.close();
+        if (partitionMarkDone != null) {
+            partitionMarkDone.close();
+        }
     }
 
     private void calcNumBytesAndRecordsOut(List<ManifestCommittable> committables) {