fix(s3stream): change reject handler to prevent task lost (#1956)

Signed-off-by: Shichao Nie <niesc@automq.com>
AutoMQ · Aug 28, 2024 · 352bf01 · 352bf01
1 parent c2977c9
commit 352bf01
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/utils/threads/S3StreamThreadPoolMonitor.java b/s3stream/src/main/java/com/automq/stream/utils/threads/S3StreamThreadPoolMonitor.java
@@ -94,7 +94,7 @@ public static ThreadPoolExecutor createAndMonitor(int corePoolSize,
             unit,
             new LinkedBlockingQueue<>(queueCapacity),
             threadFactory,
-            new ThreadPoolExecutor.DiscardOldestPolicy()) {
+            new ThreadPoolExecutor.CallerRunsPolicy()) {
             @Override
             protected void afterExecute(Runnable r, Throwable t) {
                 super.afterExecute(r, t);