인프런 커뮤니티 질문&답변

KILL-9형 도와줘,,!!!

spring boot 4.0.0, spring batch6, java24 사용중이야

 아래 코드를 스케줄러를 통해 "deleteSuspendedJob"을 1분마다 동작하게 하고 싶었어.
그리고 실제로 동작하긴 해. 딱 1번만....

    @Configuration
class DeleteSuspendedScheduler(
    private val jdbcTemplate: JdbcTemplate,
    private val jobOperator: JobOperator,
    private val jobRepository: JobRepository,
    private val transactionManager: PlatformTransactionManager,
) {

    @Scheduled(cron = "0 */1 * * * *") //1분마다 실행되길 기대함
    fun runDeleteSuspendedJob() {
        jobOperator.startNextInstance(deleteSuspendedJob())
    }

    @Bean
    fun deleteSuspendedJob(): Job =
        JobBuilder("deleteSuspendedJob", jobRepository)
            .incrementer(RunIdIncrementer())
            .start( deleteSuspendedStep())
            .build()

    @Bean
    fun deleteSuspendedStep(): Step =
        StepBuilder("deleteSuspendedStep", jobRepository)
            .tasklet(DeleteSuspendedTasklet(jdbcTemplate), transactionManager)
            .build()
}

아래는 에러 로그야.

2025-12-11T19:37:31.332+09:00  INFO 39640 --- [           main] com.clip.BatchApplicationKt              : Started BatchApplicationKt in 6.378 seconds (process running for 6.894)
2025-12-11T19:38:00.017+09:00  INFO 39640 --- [   scheduling-1] o.s.b.c.l.s.TaskExecutorJobOperator      : Launching next instance of job: [deleteSuspendedJob] with parameters: [{JobParameter{name='run.id', value=1, type=class java.lang.Long, identifying=true}}]
2025-12-11T19:38:00.019+09:00  INFO 39640 --- [   scheduling-1] o.s.b.c.l.s.TaskExecutorJobLauncher      : Job: [SimpleJob: [name=deleteSuspendedJob]] launched with the following parameters: [{JobParameter{name='run.id', value=1, type=class java.lang.Long, identifying=true}}]
2025-12-11T19:38:00.052+09:00  INFO 39640 --- [   scheduling-1] o.s.batch.core.job.SimpleStepHandler     : Executing step: [deleteSuspendedStep]
2025-12-11T19:38:00.065+09:00  INFO 39640 --- [   scheduling-1] c.c.b.b.t.DeleteExpiredBlacklistTasklet  : 0개의 기간 만료된 탈퇴 이력(재가입 방지용) 레코드가 삭제되었습니다.
2025-12-11T19:38:00.067+09:00  INFO 39640 --- [   scheduling-1] o.s.batch.core.step.AbstractStep         : Step: [deleteSuspendedStep] executed in 14ms
2025-12-11T19:38:00.067+09:00  INFO 39640 --- [   scheduling-1] o.s.b.c.l.s.TaskExecutorJobLauncher      : Job: [SimpleJob: [name=deleteSuspendedJob]] completed with the following parameters: [{JobParameter{name='run.id', value=1, type=class java.lang.Long, identifying=true}}] and the following status: [COMPLETED] in 15ms
2025-12-11T19:39:00.007+09:00  INFO 39640 --- [   scheduling-1] o.s.b.c.l.s.TaskExecutorJobOperator      : Launching next instance of job: [deleteSuspendedJob] with parameters: [{JobParameter{name='run.id', value=2, type=class java.lang.Long, identifying=true}}]
2025-12-11T19:39:00.009+09:00 ERROR 39640 --- [   scheduling-1] o.s.s.s.TaskUtils$LoggingErrorHandler    : Unexpected error occurred in scheduled task
org.springframework.batch.core.job.UnexpectedJobExecutionException: Illegal state (only happens on a race condition): job instance already complete with name=deleteSuspendedJob and parameters={JobParameter{name='run.id', value=2, type=class java.lang.Long, identifying=true}}
	at org.springframework.batch.core.launch.support.SimpleJobOperator.startNextInstance(SimpleJobOperator.java:314) ~[spring-batch-core-6.0.0.jar:6.0.0]
	at org.springframework.batch.core.launch.support.TaskExecutorJobOperator.startNextInstance(TaskExecutorJobOperator.java:133) ~[spring-batch-core-6.0.0.jar:6.0.0]
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[na:na]
	at java.base/java.lang.reflect.Method.invoke(Method.java:565) ~[na:na]
	at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:359) ~[spring-aop-7.0.1.jar:7.0.1]
	at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190) ~[spring-aop-7.0.1.jar:7.0.1]
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:158) ~[spring-aop-7.0.1.jar:7.0.1]
	at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:370) ~[spring-tx-7.0.1.jar:7.0.1]
Caused by: org.springframework.batch.core.launch.JobInstanceAlreadyCompleteException: A job instance already exists and is complete for identifying parameters={JobParameter{name='run.id', value=1, type=class java.lang.Long, identifying=true}}.  If you want to run this job again, change the parameters.
	at org.springframework.batch.core.launch.support.TaskExecutorJobLauncher.createJobExecution(TaskExecutorJobLauncher.java:149) ~[spring-batch-core-6.0.0.jar:6.0.0]
	at org.springframework.batch.core.launch.support.TaskExecutorJobLauncher.run(TaskExecutorJobLauncher.java:108) ~[spring-batch-core-6.0.0.jar:6.0.0]
	at org.springframework.batch.core.launch.support.SimpleJobOperator.startNextInstance(SimpleJobOperator.java:294) ~[spring-batch-core-6.0.0.jar:6.0.0]

원래 Kill9형 강의 보고 잡 런쳐로 정상동작 하도록 만들었던 걸, 이번에 배치6로 올리면서 JobLauncher가 JobOperator로 옮겨졌다는 문서를 보고 바꾼뒤로 퇴근을 못하고 있어,,

역시 공식 문서보단 kill9 형 문서를 보고 했어야 했던걸까??
오퍼레이터와 스케줄러를 통해 잡을 특정 주기마다 동작하는 방법(위 내 코드)이 뭐가 잘못된건지 알려주면 고맙겠어!!
형 제발 도와줘!!!

cf.https://github.com/spring-projects/spring-batch/issues/5115