Browse Source

[Bug] [API] The workflow definition and the tenant in the workflow instance are inconsistent. (#12533)

* [Bug] [API] The workflow definition and the tenant in the workflow instance are inconsistent

* fix  NPE.

Co-authored-by: houshitao <shitaohou@163.com>
3.2.0-release
houshitao 2 years ago committed by GitHub
parent
commit
547aa437ab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 4
      dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessInstanceServiceImpl.java

4
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessInstanceServiceImpl.java

@ -250,6 +250,10 @@ public class ProcessInstanceServiceImpl extends BaseServiceImpl implements Proce
logger.error("Process definition does not exist, projectCode:{}.", projectCode); logger.error("Process definition does not exist, projectCode:{}.", projectCode);
putMsg(result, Status.PROCESS_DEFINE_NOT_EXIST, processId); putMsg(result, Status.PROCESS_DEFINE_NOT_EXIST, processId);
} else { } else {
Tenant tenant = tenantMapper.queryById(processDefinition.getTenantId());
if (tenant != null) {
processDefinition.setTenantCode(tenant.getTenantCode());
}
processInstance.setLocations(processDefinition.getLocations()); processInstance.setLocations(processDefinition.getLocations());
processInstance.setDagData(processService.genDagData(processDefinition)); processInstance.setDagData(processService.genDagData(processDefinition));
result.put(DATA_LIST, processInstance); result.put(DATA_LIST, processInstance);

Loading…
Cancel
Save