스케줄러 작업 지연 및 미실행 문제 해결: misfire_grace_time 설정

스케줄러 작업이 지연되거나 실행되지 않아 중요한 갱신이 누락되는 문제가 발생했나요? 이 글에서는 misfire_grace_time 설정을 통해 이러한 문제를 해결하는 방법을 공유합니다.

시도와 함정

관찰자 기능의 일일 갱신 작업이 정체되는 현상을 겪었습니다. 처음에는 스케줄러 설정에서 misfire_grace_time 값을 늘리면 지연된 작업이 누락되지 않을 거라고 생각했습니다.

그래서 misfire_grace_time을 6시간으로 설정했습니다.

// 예시: Quartz 스케줄러 설정 (실제 사용 라이브러리에 따라 다를 수 있음)
scheduler.getListenerManager().addJobListener(new JobListener() {
    @Override
    public void jobToBeExecuted(JobExecutionContext context) {
        // 작업 실행 전 로직
    }
@Override
public void jobExecutionVetoed(JobExecutionContext context) {
    // 작업 실행 취소 로직
}

@Override
public String getName() {
    return "MyJobListener";
}

@Override
public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
    // 작업 실행 후 로직
    if (jobException != null) {
        // 에러 처리
    }
}

});
// misfire_grace_time 설정 (이 부분은 스케줄러 초기화 시점에 적용)
// 예를 들어, Spring Boot 환경이라면 properties 파일이나 Java Config에서 설정
// org.quartz.jobStore.misfireThreshold = 21600000 // 6시간 (밀리초)

하지만 단순히 misfire_grace_time만 늘리는 것으로는 근본적인 해결이 되지 않았습니다. 여전히 작업이 지연될 때 갱신 누락이 발생할 수 있다는 것을 깨달았습니다. 3시간 정도 삽질 끝에 이 부분이 전부가 아니라는 것을 알게 되었죠.

원인

스케줄러 작업이 지연될 때, 이전 실행이 끝나지 않은 상태에서 다음 실행 시점이 도래하면 작업이 누락되는 경우가 발생합니다. misfire_grace_time은 작업이 예정된 시간에 실행되지 못했을 때, 얼마나 더 기다려줄지를 설정하는 것이지만, 이 시간 동안에도 다른 이유로 작업이 시작되지 못하면 결국 누락으로 이어질 수 있습니다.

해결

이 문제를 해결하기 위해 misfire_grace_time을 6시간으로 늘리는 것과 더불어 coalesce 옵션을 적용했습니다. coalesce 옵션은 스케줄러가 동시에 여러 개의 동일한 작업을 실행하지 않도록 보장하는 역할을 합니다.

// 예시: Quartz 스케줄러 JobDetail 설정
JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
    .withIdentity("myJob", "group1")
    .usingJobData("key", "value")
    .storeDurably() // JobDetail을 저장할지 여부
    .build();
// Trigger 설정
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")
.startNow()
.withSchedule(SimpleScheduleBuilder.simpleSchedule()
.withIntervalInHours(24) // 24시간 간격
.repeatForever()
.withMisfireHandlingInstructionDoNothing() // misfire 발생 시 아무것도 하지 않음 (이후 coalesce 적용)
)
.build();
// 스케줄러에 등록
scheduler.scheduleJob(jobDetail, trigger);
// misfire_grace_time 설정 (Quartz.properties 또는 JobStore 설정)
// org.quartz.jobStore.misfireThreshold = 21600000 // 6시간 (밀리초)
// coalesce 옵션은 Quartz.properties 또는 JobStore 설정에서 활성화합니다.
// org.quartz.jobStore.useProperties = true (일반적으로 true)
// org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate (DB 종류에 따라 다름)
// coalesce 옵션은 JobStore 구현체에 따라 동작 방식이 다를 수 있으며, 명시적인 설정값보다는 JobStore의 기본 동작에 영향을 받습니다.
// 일반적으로 Quartz 2.x 버전 이상에서는 JobStore가 coalesce 로직을 포함하고 있습니다.

coalesce 옵션을 적용하면, 작업이 지연되더라도 이미 실행 중인 동일한 작업이 있다면 새로운 작업 실행을 건너뛰거나 대기하게 되어 작업 누락을 방지합니다.

결과

• 일일 갱신 작업의 지연이 발생하더라도, 갱신 누락이 더 이상 발생하지 않게 되었습니다.
• 스케줄러의 안정성이 확보되어 관찰자 기능의 데이터 일관성을 유지할 수 있었습니다.
• 기존 로직 변경 없이 스케줄러 설정만으로 문제를 해결하여 개발 부담을 줄였습니다.

정리 — 같은 함정 안 빠지려면

• [ ] 스케줄러 작업 지연 시 갱신 누락이 발생하는지 모니터링합니다.
• [ ] misfire_grace_time 설정을 통해 작업 지연 허용 시간을 충분히 확보합니다. (예: 6시간)
• [ ] coalesce 옵션이 활성화되어 있는지 확인하거나, JobStore가 해당 기능을 지원하는지 확인합니다.
• [ ] 스케줄러의 로그를 주기적으로 확인하여 예상치 못한 misfire나 지연이 발생하는지 점검합니다.