You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by li...@apache.org on 2022/10/10 06:01:11 UTC
[dolphinscheduler] branch dev updated: [Fix#12231][scheduler-plugin] fix the bug which some scheduled tasks are not triggered on time (#12233)
This is an automated email from the ASF dual-hosted git repository.
lidongdai 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 d9ac1fa0f7 [Fix#12231][scheduler-plugin] fix the bug which some scheduled tasks are not triggered on time (#12233)
d9ac1fa0f7 is described below
commit d9ac1fa0f70322de4985285231058f6a2e353325
Author: Ivan <wa...@gmail.com>
AuthorDate: Mon Oct 10 14:01:02 2022 +0800
[Fix#12231][scheduler-plugin] fix the bug which some scheduled tasks are not triggered on time (#12233)
Co-authored-by: fan.wang <fa...@jiduauto.com>
---
.../org/apache/dolphinscheduler/scheduler/quartz/QuartzScheduler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/QuartzScheduler.java b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/QuartzScheduler.java
index 1025a2918f..6ca8dc1037 100644
--- a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/QuartzScheduler.java
+++ b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/QuartzScheduler.java
@@ -111,7 +111,7 @@ public class QuartzScheduler implements SchedulerApi {
.endAt(endDate)
.withSchedule(
cronSchedule(cronExpression)
- .withMisfireHandlingInstructionDoNothing()
+ .withMisfireHandlingInstructionFireAndProceed()
.inTimeZone(DateUtils.getTimezone(timezoneId))
)
.forJob(jobDetail).build();