(flink-cdc) branch master updated: [FLINK-39144][paimon] Fix ioManager close.(#4283)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new e77901552 [FLINK-39144][paimon] Fix ioManager close.(#4283)
e77901552 is described below

commit e77901552cacfdbe0ca43a94f8101fb440d510d9
Author: Pei Yu <125331...@qq.com>
AuthorDate: Tue Feb 24 19:28:13 2026 +0800

    [FLINK-39144][paimon] Fix ioManager close.(#4283)
    
    Signed-off-by: peiyu <125331...@qq.com>
---
 .../org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java   | 3 +++
 1 file changed, 3 insertions(+)

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
index 0b09a560a..555086f41 100644
--- 
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 class PaimonWriter<InputT>
         if (compactExecutor != null) {
             compactExecutor.shutdownNow();
         }
+        if (ioManager != null) {
+            ioManager.close();
+        }
     }
 
     @Override