shutdown the closeWritersExecutor

apache · Oct 18, 2024 · 899926a · 899926a
1 parent b34433a
commit 899926a
Showing 1 changed file with 3 additions and 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
@@ -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) {