Browse Source

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

final/10.0.3
Lanlan 6 years ago
parent
commit
638f7ac4fe
  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) { for (TriggerKey triggerKey : misfiredTriggers) {
try {
OperableTrigger trig =
retrieveTrigger(conn, triggerKey);
OperableTrigger trig = if (trig == null) {
retrieveTrigger(conn, triggerKey); 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) if (trig.getNextFireTime() != null && trig.getNextFireTime().getTime() < earliestNewTime)
earliestNewTime = trig.getNextFireTime().getTime(); earliestNewTime = trig.getNextFireTime().getTime();
} catch (JobPersistenceException e) {
getLog().error(e.getMessage());
}
} }
return new RecoverMisfiredJobsResult( return new RecoverMisfiredJobsResult(

Loading…
Cancel
Save