[FLINK-39144][paimon] Fix ioManager close.(apache#4283)

sd4324530 · Mrart · commit 418f6f465e1a · 2026-03-26T16:57:00.000+08:00
Signed-off-by: peiyu &lt;125331682@qq.com&gt;
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java
@@ -224,6 +224,9 @@ public void close() throws Exception {
         if (compactExecutor != null) {
             compactExecutor.shutdownNow();
         }
+        if (ioManager != null) {
+            ioManager.close();
+        }
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -224,6 +224,9 @@ public void close() throws Exception {`
`224`	`224`	`if (compactExecutor != null) {`
`225`	`225`	`compactExecutor.shutdownNow();`
`226`	`226`	`}`
	`227`	`+ if (ioManager != null) {`
	`228`	`+ ioManager.close();`
	`229`	`+ }`
`227`	`230`	`}`
`228`	`231`
`229`	`232`	`@Override`