From 5fced1497ba2d36c18847edce84f84ed972107ee Mon Sep 17 00:00:00 2001
From: qiaozhanwei <qiaozhanwei@analysys.com.cn>
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);