diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerService.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerService.java index f8a1ef6a9e..2202cc57fb 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerService.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerService.java @@ -179,10 +179,6 @@ public class MasterSchedulerService extends Thread { } private List command2ProcessInstance(List commands) { - if (CollectionUtils.isEmpty(commands)) { - return null; - } - List processInstances = new ArrayList<>(commands.size()); CountDownLatch latch = new CountDownLatch(commands.size()); for (final Command command : commands) {