Fix ut error

CalvinKirs · Oct 31, 2023 · e6b113d · e6b113d
1 parent 48483dc
commit e6b113d
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/scheduler/job/JobTask.java b/fe/fe-core/src/main/java/org/apache/doris/scheduler/job/JobTask.java
@@ -17,7 +17,6 @@
 
 package org.apache.doris.scheduler.job;
 
-import lombok.extern.slf4j.Slf4j;
 import org.apache.doris.common.io.Text;
 import org.apache.doris.common.io.Writable;
 import org.apache.doris.common.util.TimeUtils;
@@ -27,6 +26,7 @@
 import com.google.common.collect.Lists;
 import com.google.gson.annotations.SerializedName;
 import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -56,7 +56,7 @@ public class JobTask<T> implements Writable {
     private String executeResult;
     @SerializedName("errorMsg")
     private String errorMsg;
-    
+
     @SerializedName("contextDataStr")
     private String contextDataStr;
 

diff --git a/fe/fe-core/src/test/java/org/apache/doris/scheduler/disruptor/TaskDisruptorTest.java b/fe/fe-core/src/test/java/org/apache/doris/scheduler/disruptor/TaskDisruptorTest.java
@@ -59,6 +59,7 @@ public class TaskDisruptorTest {
     @BeforeEach
     public void init() {
         taskDisruptor = new TaskDisruptor(timerJobManager, transientTaskManager);
+        taskDisruptor.start();
     }
 
     @Test

diff --git a/fe/fe-core/src/test/java/org/apache/doris/scheduler/disruptor/TimerJobManagerTest.java b/fe/fe-core/src/test/java/org/apache/doris/scheduler/disruptor/TimerJobManagerTest.java
@@ -65,6 +65,7 @@ public void init() {
         TransientTaskManager transientTaskManager = new TransientTaskManager();
         TaskDisruptor taskDisruptor = new TaskDisruptor(this.timerJobManager, transientTaskManager);
         this.timerJobManager.setDisruptor(taskDisruptor);
+        taskDisruptor.start();
         timerJobManager.start();
     }