[core] Fix cache thread pool in FileDeletionThreadPool (apache#3767)

askwang · Jul 17, 2024 · b0a3b87 · b0a3b87
1 parent f349615
commit b0a3b87
Showing 1 changed file with 10 additions and 7 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/utils/FileDeletionThreadPool.java b/paimon-common/src/main/java/org/apache/paimon/utils/FileDeletionThreadPool.java
@@ -44,12 +44,15 @@ public static synchronized ThreadPoolExecutor getExecutorService(int threadNum)
     }
 
     private static ThreadPoolExecutor createCachedThreadPool(int threadNum) {
-        return new ThreadPoolExecutor(
-                0,
-                threadNum,
-                1,
-                TimeUnit.MINUTES,
-                new LinkedBlockingQueue<>(),
-                newDaemonThreadFactory("DELETE-FILE-THREAD-POOL"));
+        ThreadPoolExecutor executor =
+                new ThreadPoolExecutor(
+                        threadNum,
+                        threadNum,
+                        1,
+                        TimeUnit.MINUTES,
+                        new LinkedBlockingQueue<>(),
+                        newDaemonThreadFactory("DELETE-FILE-THREAD-POOL"));
+        executor.allowCoreThreadTimeOut(true);
+        return executor;
     }
 }