From 5fced1497ba2d36c18847edce84f84ed972107ee Mon Sep 17 00:00:00 2001 From: qiaozhanwei Date: Mon, 13 May 2019 14:09:26 +0800 Subject: [PATCH] If there is a scheduled time, take the scheduling time. Recovery from failed nodes, suspension of recovery, re-run for scheduling --- .../common/utils/placeholder/BusinessTimeUtils.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/escheduler-common/src/main/java/cn/escheduler/common/utils/placeholder/BusinessTimeUtils.java b/escheduler-common/src/main/java/cn/escheduler/common/utils/placeholder/BusinessTimeUtils.java index 5dc996bcc5..4af0ccf582 100644 --- a/escheduler-common/src/main/java/cn/escheduler/common/utils/placeholder/BusinessTimeUtils.java +++ b/escheduler-common/src/main/java/cn/escheduler/common/utils/placeholder/BusinessTimeUtils.java @@ -50,9 +50,16 @@ public class BusinessTimeUtils { case RECOVER_TOLERANCE_FAULT_PROCESS: case RECOVER_SUSPENDED_PROCESS: case START_FAILURE_TASK_PROCESS: + case REPEAT_RUNNING: case SCHEDULER: default: businessDate = addDays(new Date(), -1); + if (businessDate != null){ + /** + * If there is a scheduled time, take the scheduling time. Recovery from failed nodes, suspension of recovery, re-run for scheduling + */ + businessDate = runTime; + } break; } Date businessCurrentDate = addDays(businessDate, 1);