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;
}