[core] Fix cache thread pool in FileDeletionThreadPool

apache · Jul 17, 2024 · 767f9c1 · 767f9c1
1 parent ae77340
commit 767f9c1
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -21,6 +21,7 @@
 import org.apache.paimon.fs.FileIO;
 
 import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.SynchronousQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 
@@ -49,7 +50,7 @@ private static ThreadPoolExecutor createCachedThreadPool(int threadNum) {
                 threadNum,
                 1,
                 TimeUnit.MINUTES,
-                new LinkedBlockingQueue<>(),
+                new SynchronousQueue<>(),
                 newDaemonThreadFactory("DELETE-FILE-THREAD-POOL"));
     }
 }