[Fix](Job)Replace BlockingWaitStrategy with LiteTimeoutBlockingWaitSt…

…rategy to avoid
CalvinKirs · Sep 10, 2024 · 33e6ed1 · 33e6ed1
1 parent aa8f6bf
commit 33e6ed1
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java b/fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java
@@ -44,7 +44,7 @@
 @Log4j2
 public class TaskDisruptor implements Closeable {
 
-    private  Disruptor<TaskEvent> disruptor;
+    private Disruptor<TaskEvent> disruptor;
     private static final int DEFAULT_RING_BUFFER_SIZE = Config.async_task_queen_size;
 
     private static final int consumerThreadCount = Config.async_task_consumer_thread_num;
@@ -66,10 +66,10 @@ public class TaskDisruptor implements Closeable {
      */
     private static final EventTranslatorThreeArg<TaskEvent, Long, Long, TaskType> TRANSLATOR
             = (event, sequence, jobId, taskId, taskType) -> {
-        event.setId(jobId);
-        event.setTaskId(taskId);
-        event.setTaskType(taskType);
-    };
+                event.setId(jobId);
+                event.setTaskId(taskId);
+                event.setTaskType(taskType);
+            };
 
     public void start() {
         CustomThreadFactory exportTaskThreadFactory = new CustomThreadFactory("export-task-consumer");