fix UT

apache · Jun 1, 2022 · 03f4025 · 03f4025
1 parent 01ab475
commit 03f4025
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...er/src/test/java/org/apache/dolphinscheduler/server/master/WorkflowExecuteThreadTest.java b/...er/src/test/java/org/apache/dolphinscheduler/server/master/WorkflowExecuteThreadTest.java
@@ -21,7 +21,6 @@
 import static org.apache.dolphinscheduler.common.Constants.CMDPARAM_COMPLEMENT_DATA_START_DATE;
 import static org.apache.dolphinscheduler.common.Constants.CMD_PARAM_RECOVERY_START_NODE_STRING;
 import static org.apache.dolphinscheduler.common.Constants.CMD_PARAM_START_NODES;
-
 import static org.powermock.api.mockito.PowerMockito.mock;
 
 import org.apache.dolphinscheduler.common.enums.CommandType;
@@ -38,7 +37,6 @@
 import org.apache.dolphinscheduler.server.master.config.MasterConfig;
 import org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread;
 import org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread;
-import org.apache.dolphinscheduler.server.master.runner.task.TaskProcessorFactory;
 import org.apache.dolphinscheduler.service.bean.SpringApplicationContext;
 import org.apache.dolphinscheduler.service.process.ProcessService;
 
@@ -85,8 +83,6 @@ public class WorkflowExecuteThreadTest {
 
     private ApplicationContext applicationContext;
 
-    private TaskProcessorFactory taskProcessorFactory;
-
     private StateWheelExecuteThread stateWheelExecuteThread;
 
     @Before
@@ -101,8 +97,6 @@ public void init() throws Exception {
         processService = mock(ProcessService.class);
         Mockito.when(applicationContext.getBean(ProcessService.class)).thenReturn(processService);
 
-        taskProcessorFactory = mock(TaskProcessorFactory.class);
-
         processInstance = mock(ProcessInstance.class);
         Mockito.when(processInstance.getState()).thenReturn(ExecutionStatus.SUCCESS);
         Mockito.when(processInstance.getHistoryCmd()).thenReturn(CommandType.COMPLEMENT_DATA.toString());