This is an automated email from the ASF dual-hosted git repository.

zhongjiajie 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 dec28b5c2e [improve] Correct some log in scheduler (#12278)
dec28b5c2e is described below

commit dec28b5c2ebe08166dd251f7b3c27236a5c2f13e
Author: fuchanghai <[email protected]>
AuthorDate: Mon Oct 10 09:42:57 2022 +0800

    [improve] Correct some log in scheduler (#12278)
---
 .../apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
 
b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
index 2b546940ec..898fb1e4be 100644
--- 
a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
+++ 
b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
@@ -61,7 +61,7 @@ public class ProcessScheduleTask extends QuartzJobBean {
 
         Date fireTime = context.getFireTime();
 
-        logger.info("scheduled fire time :{}, fire time :{}, process id :{}", 
scheduledFireTime, fireTime, scheduleId);
+        logger.info("scheduled fire time :{}, fire time :{}, scheduleId :{}", 
scheduledFireTime, fireTime, scheduleId);
 
         // query schedule
         Schedule schedule = processService.querySchedule(scheduleId);
@@ -75,7 +75,7 @@ public class ProcessScheduleTask extends QuartzJobBean {
         // release state : online/offline
         ReleaseState releaseState = processDefinition.getReleaseState();
         if (releaseState == ReleaseState.OFFLINE) {
-            logger.warn("process definition does not exist in db or 
offline,need not to create command, projectId:{}, processId:{}", projectId, 
processDefinition.getId());
+            logger.warn("process definition does not exist in db or 
offline,need not to create command, projectId:{}, processDefinitionId:{}", 
projectId, processDefinition.getId());
             return;
         }
 

Reply via email to