Browse Source

[DS-6362][fix] fix switch process definition version failed (#6363)

2.0.7-release
ououtt 3 years ago committed by GitHub
parent
commit
652d690976
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java
  2. 2
      dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

2
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessDefinitionServiceImpl.java

@ -1395,7 +1395,7 @@ public class ProcessDefinitionServiceImpl extends BaseServiceImpl implements Pro
return result; return result;
} }
int switchVersion = processService.switchVersion(processDefinition, processDefinitionLog); int switchVersion = processService.switchVersion(processDefinition, processDefinitionLog);
if (switchVersion > 0) { if (switchVersion <= 0) {
putMsg(result, Status.SWITCH_PROCESS_DEFINITION_VERSION_ERROR); putMsg(result, Status.SWITCH_PROCESS_DEFINITION_VERSION_ERROR);
throw new ServiceException(Status.SWITCH_PROCESS_DEFINITION_VERSION_ERROR); throw new ServiceException(Status.SWITCH_PROCESS_DEFINITION_VERSION_ERROR);
} }

2
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

@ -2212,7 +2212,7 @@ public class ProcessService {
int result = processDefineMapper.updateById(processDefinitionLog); int result = processDefineMapper.updateById(processDefinitionLog);
if (result > 0) { if (result > 0) {
result = switchProcessTaskRelationVersion(processDefinition); result = switchProcessTaskRelationVersion(processDefinitionLog);
if (result <= 0) { if (result <= 0) {
return Constants.DEFINITION_FAILURE; return Constants.DEFINITION_FAILURE;
} }

Loading…
Cancel
Save