in kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobScheduleController.java [158:174]
public synchronized void triggerJob() {
try {
if (scheduler.isShutdown()) {
return;
}
if (!scheduler.checkExists(jobDetail.getKey())) {
scheduler.scheduleJob(jobDetail, createOneOffTrigger());
} else {
scheduler.triggerJob(jobDetail.getKey());
}
if (!scheduler.isStarted()) {
scheduler.start();
}
} catch (final SchedulerException ex) {
throw new JobSystemException(ex);
}
}