[incubator-dolphinscheduler] branch dev-1.2.1 updated: donot submit task to queue if sub process (#1793)

[lgcareer]

This is an automated email from the ASF dual-hosted git repository.

lgcareer pushed a commit to branch dev-1.2.1
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/dev-1.2.1 by this push:
     new 8c724d1  donot submit task to queue if sub process (#1793)
8c724d1 is described below

commit 8c724d1f6d397df3d14619bfcd1f93aab9315026
Author: bao liang <29528966+len...@users.noreply.github.com>
AuthorDate: Fri Jan 10 16:44:48 2020 +0800

    donot submit task to queue if sub process (#1793)
---
 .../src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java
 
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java
index 3cf2885..2d487b8 100644
--- 
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java
+++ 
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/ProcessDao.java
@@ -972,6 +972,9 @@ public class ProcessDao {
     public Boolean submitTaskToQueue(TaskInstance taskInstance) {
 
         try{
+            if(taskInstance.isSubProcess()){
+                return true;
+            }
             if(taskInstance.getState().typeIsFinished()){
                 logger.info(String.format("submit to task queue, but task [%s] 
state [%s] is already  finished. ", taskInstance.getName(), 
taskInstance.getState().toString()));
                 return true;