From 79bba7d42579000277cceffdfd0b077dce6e1205 Mon Sep 17 00:00:00 2001
From: peiyu <125331682@qq.com>
Date: Tue, 24 Feb 2026 15:54:25 +0800
Subject: [PATCH] fix ioManager close.

Signed-off-by: peiyu <125331682@qq.com>
---
 .../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 0b09a560a4e..555086f41f9 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 void close() throws Exception {
         if (compactExecutor != null) {
             compactExecutor.shutdownNow();
         }
+        if (ioManager != null) {
+            ioManager.close();
+        }
     }
 
     @Override