You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ji...@apache.org on 2021/11/15 12:27:27 UTC
[dolphinscheduler] branch dev updated: [Feature][Master] change sub process id to code (#6858)
This is an automated email from the ASF dual-hosted git repository.
jinyleechina pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 1160b53 [Feature][Master] change sub process id to code (#6858)
1160b53 is described below
commit 1160b53940c8cc4457b1604514c5c6ba1a13b153
Author: OS <29...@users.noreply.github.com>
AuthorDate: Mon Nov 15 20:27:19 2021 +0800
[Feature][Master] change sub process id to code (#6858)
* feature 6597 change sub process id to code
* feature 6597 change sub process id to code
---
.../org/apache/dolphinscheduler/service/process/ProcessService.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
index 8e8b51a..13154e8 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
@@ -1280,7 +1280,10 @@ public class ProcessService {
TaskInstance task) {
CommandType commandType = getSubCommandType(parentProcessInstance, childInstance);
Map<String, String> subProcessParam = JSONUtils.toMap(task.getTaskParams());
- int childDefineCode = Integer.parseInt(subProcessParam.get(Constants.CMD_PARAM_SUB_PROCESS_DEFINE_CODE));
+ long childDefineCode = 0L;
+ if (subProcessParam.containsKey(Constants.CMD_PARAM_SUB_PROCESS_DEFINE_CODE)) {
+ childDefineCode = Long.parseLong(subProcessParam.get(Constants.CMD_PARAM_SUB_PROCESS_DEFINE_CODE));
+ }
ProcessDefinition subProcessDefinition = processDefineMapper.queryByCode(childDefineCode);
Object localParams = subProcessParam.get(Constants.LOCAL_PARAMS);