This is an automated email from the ASF dual-hosted git repository. wenjun pushed a commit to branch 3.0.0-prepare in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit da03ef32e93daf103d44845db21f5614ebd9cfe7 Author: Wenjun Ruan <[email protected]> AuthorDate: Tue Jul 19 12:00:37 2022 +0800 Fix compile error --- .../apache/dolphinscheduler/service/process/ProcessServiceTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java b/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java index e19a992b83..a98138dd03 100644 --- a/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java +++ b/dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java @@ -371,7 +371,7 @@ public class ProcessServiceTest { command5.setCommandType(CommandType.START_PROCESS); command5.setDryRun(Constants.DRY_RUN_FLAG_NO); Mockito.when(commandMapper.deleteById(5)).thenReturn(1); - ProcessInstance processInstance1 = processService.handleCommand(logger, host, command5); + ProcessInstance processInstance1 = processService.handleCommand(host, command5); Assert.assertTrue(processInstance1.getGlobalParams().contains("\"testStartParam1\"")); ProcessDefinition processDefinition1 = new ProcessDefinition(); @@ -426,7 +426,7 @@ public class ProcessServiceTest { command7.setProcessDefinitionVersion(1); Mockito.when(commandMapper.deleteById(7)).thenReturn(1); Mockito.when(processInstanceMapper.queryByProcessDefineCodeAndProcessDefinitionVersionAndStatusAndNextId(11L, 1, Constants.RUNNING_PROCESS_STATE, 224)).thenReturn(null); - ProcessInstance processInstance8 = processService.handleCommand(logger, host, command7); + ProcessInstance processInstance8 = processService.handleCommand(host, command7); Assert.assertTrue(processInstance8 == null); ProcessDefinition processDefinition2 = new ProcessDefinition();
