From 899926a6c3a81df1f81e06a41599c773f4d4cfb1 Mon Sep 17 00:00:00 2001
From: HouliangQi <neuyilan@163.com>
Date: Fri, 18 Oct 2024 15:14:34 +0800
Subject: [PATCH] shutdown the closeWritersExecutor

---
 .../org/apache/paimon/operation/AbstractFileStoreWrite.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java b/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
index f5526b4aaed8..b90509b1e902 100644
--- a/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
+++ b/paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java
@@ -368,7 +368,9 @@ public void close() throws Exception {
         CompletableFuture<Void> allTasksDone =
                 CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));
         allTasksDone.get();
-        ExecutorUtils.gracefulShutdown(1, TimeUnit.MINUTES, closeWritersExecutor);
+        if (closeWritersExecutor != null) {
+            closeWritersExecutor.shutdownNow();
+        }
 
         writers.clear();
         if (lazyCompactExecutor != null && closeCompactExecutorWhenLeaving) {