Spring Batch定时作业完成后如何重置状态以实现重试成功后启动新执行？

Spring Batch的作业实例身份由作业名称+JobParameters唯一确定，默认规则下状态为COMPLETED的作业实例不允许再次启动，这是框架自带的幂等保护机制，不建议直接修改元数据表强行重置状态，会破坏作业执行轨迹的可追溯性。

针对你「重复执行同一个作业实例直至无错误完成，之后再启动新实例」的需求，可以通过查询作业历史状态动态判断启动逻辑来实现，具体方案如下：

实现步骤 #

1. 引入JobExplorer查询作业历史状态 #

注入JobExplorer组件查询已有的作业实例和执行记录，动态判断是重启旧实例还是启动新实例：

@Component
class JobScheduler {

    @Autowired
    private Job job1;

    @Autowired
    private JobLauncher jobLauncher;

    @Autowired
    private JobExplorer jobExplorer;

    @Scheduled(cron = "0 0/15 * * * ?")
    public void launchJob1() throws Exception {
        // 查询job1最近的1个作业实例
        List<JobInstance> jobInstances = jobExplorer.findJobInstancesByJobName("job1", 0, 1);
        JobParameters jobParameters;
        if (CollectionUtils.isEmpty(jobInstances)) {
            // 首次运行，生成带业务标识的参数（示例为按天的业务日期，可根据实际业务调整）
            jobParameters = new JobParametersBuilder()
                    .addString("businessDate", LocalDate.now().toString())
                    .toJobParameters();
        } else {
            JobInstance lastInstance = jobInstances.get(0);
            JobExecution lastExecution = jobExplorer.getJobExecutions(lastInstance).get(0);
            if (BatchStatus.COMPLETED.equals(lastExecution.getStatus())) {
                // 上一个实例已成功完成，生成新参数启动新实例
                jobParameters = new JobParametersBuilder()
                        .addString("businessDate", LocalDate.now().toString())
                        .toJobParameters();
            } else {
                // 上一个实例未执行成功，复用原有参数重启同一个实例
                jobParameters = lastInstance.getJobParameters();
            }
        }
        jobLauncher.run(job1, jobParameters);
    }
}

2. 调整作业流向配置适配重试逻辑 #

你原有代码中step1返回NOT_READY状态时直接走end()，此时作业最终状态为COMPLETED，会被识别为执行完成无法重启。如果NOT_READY属于需要重试的场景，需要调整为fail()，让作业进入可重启的FAILED状态：

@Bean
public Job job1() {
    return this.jobBuilderFactory.get("job1")
        // 确保没有配置preventRestart()，该配置会禁止作业重启
        .start(this.step1()).on(STEP1_STATUS.NOT_READY.get()).fail()
        .from(this.step1()).on(STEP1_STATUS.READY.get()).to(this.step2())
        .next(this.step3())
        .end()
        .build();
}

注意事项 #

• 只有状态为FAILED、STOPPED的作业实例可以被重启，COMPLETED状态为终态，即使复用参数也无法启动，刚好匹配你完成后再开新实例的需求。
• JobParameters建议使用业务维度的标识（比如业务日期、批次号），不要用随机数或实时时间戳，确保同一个业务周期的作业会被识别为同一个实例。
• 禁止直接修改Spring Batch元数据表（BATCH_JOB_EXECUTION、BATCH_JOB_INSTANCE等）的状态字段，会导致执行日志混乱，提高问题排查成本。

内容的提问来源于stack exchange，提问作者maqjav