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,

Reply via email to