From e2ec489042d59e4f63c181345da0da3d23f2a642 Mon Sep 17 00:00:00 2001 From: WangJPLeo <103574007+WangJPLeo@users.noreply.github.com> Date: Wed, 20 Apr 2022 15:04:27 +0800 Subject: [PATCH] [Fix-9610] Sub-workflow status check is limited to SUB_PROCESS components (#9611) * Sub-workflow status check is limited to SUB_PROCESS components * Sub-workflow status check is limited to SUB_PROCESS components Co-authored-by: WangJPLeo --- .../dolphinscheduler/api/service/impl/ExecutorServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java index 33cc6a2fbe..8fd4ce47d6 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java @@ -248,6 +248,9 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ taskDefinitions.stream() .filter(task -> TaskConstants.TASK_TYPE_SUB_PROCESS.equalsIgnoreCase(task.getTaskType())) .forEach(taskDefinition -> processDefinitionCodeSet.add(Long.valueOf(JSONUtils.getNodeString(taskDefinition.getTaskParams(), Constants.CMD_PARAM_SUB_PROCESS_DEFINE_CODE)))); + if (processDefinitionCodeSet.isEmpty()){ + return true; + } // check sub releaseState List processDefinitions = processDefinitionMapper.queryByCodes(processDefinitionCodeSet);