You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by li...@apache.org on 2020/01/22 15:16:21 UTC
[incubator-dolphinscheduler] branch dev updated: #1864 fix
dependency and createCommand date check (#1865)
This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new ff9009a #1864 fix dependency and createCommand date check (#1865)
ff9009a is described below
commit ff9009a5aeef3df1c2031f9bc2eaa094b9dc833c
Author: Jave-Chen <ac...@126.com>
AuthorDate: Wed Jan 22 23:16:13 2020 +0800
#1864 fix dependency and createCommand date check (#1865)
---
dolphinscheduler-api/pom.xml | 4 ++++
.../java/org/apache/dolphinscheduler/api/service/ExecutorService.java | 4 ----
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/dolphinscheduler-api/pom.xml b/dolphinscheduler-api/pom.xml
index 1c0ba5e..cf2aadf 100644
--- a/dolphinscheduler-api/pom.xml
+++ b/dolphinscheduler-api/pom.xml
@@ -43,6 +43,10 @@
<groupId>org.apache.dolphinscheduler</groupId>
<artifactId>dolphinscheduler-dao</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.apache.dolphinscheduler</groupId>
+ <artifactId>dolphinscheduler-server</artifactId>
+ </dependency>
<!--springboot-->
<dependency>
diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ExecutorService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ExecutorService.java
index 3296624..c1689c5 100644
--- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ExecutorService.java
+++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/ExecutorService.java
@@ -499,10 +499,6 @@ public class ExecutorService extends BaseService{
}
}
- if ( start == null || end == null) {
- return 0;
- }
-
if(commandType == CommandType.COMPLEMENT_DATA){
runMode = (runMode == null) ? RunMode.RUN_MODE_SERIAL : runMode;
if(null != start && null != end && start.before(end)){