diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java index 88a1937b59..83d7fb1ca9 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java @@ -672,6 +672,11 @@ public class WorkflowExecuteRunnable implements Callable { Date scheduleDate = processInstance.getScheduleTime(); if (scheduleDate == null) { + if (CollectionUtils.isEmpty(complementListDate)) { + log.info("complementListDate is empty, process complement end. process id:{}", processInstance.getId()); + + return true; + } scheduleDate = complementListDate.get(0); } else if (processInstance.getState().isFinished()) { endProcess();