You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ch...@apache.org on 2022/11/07 07:39:16 UTC

[dolphinscheduler] branch 3.0.2-prepare updated: [Fix#12231][scheduler-plugin] fix the bug which some scheduled tasks are not triggered on time (#12233) (#12767)

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

chufenggao pushed a commit to branch 3.0.2-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/3.0.2-prepare by this push:
     new 7d998879ef [Fix#12231][scheduler-plugin] fix the bug which some scheduled tasks are not triggered on time (#12233) (#12767)
7d998879ef is described below

commit 7d998879effccc333f07bae9b9d779083df36529
Author: Eric Gao <er...@gmail.com>
AuthorDate: Mon Nov 7 15:39:09 2022 +0800

    [Fix#12231][scheduler-plugin] fix the bug which some scheduled tasks are not triggered on time (#12233) (#12767)
    
    Co-authored-by: fan.wang <fa...@jiduauto.com>
    Co-authored-by: Ivan <wa...@gmail.com>
    Co-authored-by: fan.wang <fa...@jiduauto.com>
---
 .../apache/dolphinscheduler/service/quartz/impl/QuartzExecutorImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/impl/QuartzExecutorImpl.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/impl/QuartzExecutorImpl.java
index b4d5ee9246..78e12717d1 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/impl/QuartzExecutorImpl.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/impl/QuartzExecutorImpl.java
@@ -123,7 +123,7 @@ public class QuartzExecutorImpl implements QuartzExecutor {
                     .endAt(endDate)
                     .withSchedule(
                             cronSchedule(cronExpression)
-                                    .withMisfireHandlingInstructionDoNothing()
+                                    .withMisfireHandlingInstructionFireAndProceed()
                                     .inTimeZone(DateUtils.getTimezone(timezoneId))
                     )
                     .forJob(jobDetail).build();