diff --git a/dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/BusinessTimeUtils.java b/dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/BusinessTimeUtils.java index b35598d42e..56ee124866 100644 --- a/dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/BusinessTimeUtils.java +++ b/dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/task/paramparser/BusinessTimeUtils.java @@ -26,6 +26,7 @@ import static org.apache.dolphinscheduler.spi.utils.DateUtils.addDays; import static org.apache.dolphinscheduler.spi.utils.DateUtils.format; import org.apache.dolphinscheduler.spi.enums.CommandType; +import org.apache.dolphinscheduler.spi.utils.DateUtils; import java.util.Date; import java.util.HashMap; @@ -47,9 +48,10 @@ public class BusinessTimeUtils { * @return business time */ public static Map getBusinessTime(CommandType commandType, Date runTime) { - Date businessDate = runTime; + Date businessDate; switch (commandType) { case COMPLEMENT_DATA: + businessDate = DateUtils.addDays(runTime, -1); break; case START_PROCESS: case START_CURRENT_TASK_PROCESS: