diff --git a/fine-quartz/src/com/fr/third/v2/org/quartz/impl/jdbcjobstore/JobStoreSupport.java b/fine-quartz/src/com/fr/third/v2/org/quartz/impl/jdbcjobstore/JobStoreSupport.java index d6fcef079..4f3a3d6b0 100644 --- a/fine-quartz/src/com/fr/third/v2/org/quartz/impl/jdbcjobstore/JobStoreSupport.java +++ b/fine-quartz/src/com/fr/third/v2/org/quartz/impl/jdbcjobstore/JobStoreSupport.java @@ -982,18 +982,21 @@ public abstract class JobStoreSupport implements JobStore, Constants { } for (TriggerKey triggerKey : misfiredTriggers) { + try { + OperableTrigger trig = + retrieveTrigger(conn, triggerKey); - OperableTrigger trig = - retrieveTrigger(conn, triggerKey); - - if (trig == null) { - continue; - } + if (trig == null) { + continue; + } - doUpdateOfMisfiredTrigger(conn, trig, false, STATE_WAITING, recovering); + doUpdateOfMisfiredTrigger(conn, trig, false, STATE_WAITING, recovering); - if (trig.getNextFireTime() != null && trig.getNextFireTime().getTime() < earliestNewTime) - earliestNewTime = trig.getNextFireTime().getTime(); + if (trig.getNextFireTime() != null && trig.getNextFireTime().getTime() < earliestNewTime) + earliestNewTime = trig.getNextFireTime().getTime(); + } catch (JobPersistenceException e) { + getLog().error(e.getMessage()); + } } return new RecoverMisfiredJobsResult(