Browse Source

DEC-8173 脏数据导致quartz启动失败

bugfix/10.0
Lanlan 5 years ago
parent
commit
978eccd5be
  1. 21
      fine-quartz/src/com/fr/third/v2/org/quartz/impl/jdbcjobstore/JobStoreSupport.java

21
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(

Loading…
Cancel
Save