This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch 1.3.8-release
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/1.3.8-release by this push:
new b7cc822 [FIX:211114]add default processInstancePriority (#6690)
b7cc822 is described below
commit b7cc822d0966657de0b6c69f96b03e7b8794257e
Author: 小张 <[email protected]>
AuthorDate: Thu Nov 4 17:02:27 2021 +0800
[FIX:211114]add default processInstancePriority (#6690)
Co-authored-by: 张柏强 <[email protected]>
---
.../apache/dolphinscheduler/api/controller/SchedulerController.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/SchedulerController.java
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/SchedulerController.java
index a9a5514..b159e06 100644
---
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/SchedulerController.java
+++
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/SchedulerController.java
@@ -52,6 +52,7 @@ public class SchedulerController extends BaseController {
public static final String DEFAULT_WARNING_TYPE = "NONE";
public static final String DEFAULT_NOTIFY_GROUP_ID = "1";
public static final String DEFAULT_FAILURE_POLICY = "CONTINUE";
+ public static final String DEFAULT_PROCESS_INSTANCE_PRIORITY = "2";
@Autowired
@@ -99,7 +100,7 @@ public class SchedulerController extends BaseController {
@RequestParam(value = "receivers", required =
false) String receivers,
@RequestParam(value = "receiversCc", required
= false) String receiversCc,
@RequestParam(value = "workerGroup", required
= false, defaultValue = "default") String workerGroup,
- @RequestParam(value =
"processInstancePriority", required = false) Priority processInstancePriority)
throws IOException {
+ @RequestParam(value =
"processInstancePriority", required = false, defaultValue =
DEFAULT_PROCESS_INSTANCE_PRIORITY) Priority processInstancePriority) throws
IOException {
logger.info("login user {}, project name: {}, process name: {}, create
schedule: {}, warning type: {}, warning group id: {}," +
"failure policy: {},receivers : {},receiversCc :
{},processInstancePriority : {}, workGroupId:{}",
loginUser.getUserName(), projectName, processDefinitionId,
schedule, warningType, warningGroupId,