Spring Batch异常终止后，如何测试从断点Chunk重启作业？

问题现状 #

• 作业中断后状态：job execution-exit_code = unknown，step execution-exit_code = started
• 重启尝试的两种情况：
  1. 使用incrementer(new RunIdIncrementer())：每次生成新的JobParameters，启动全新作业，无法复用中断的作业实例
  2. 移除incrementer后：系统提示不允许重复JobParameters，无法重启中断作业
• 核心需求：作业未完成时，能否从中断的Chunk位置继续执行？是否遗漏关键配置/操作？

配置调整与重启验证步骤 #

1. 确保作业允许重启 #

Spring Batch默认支持作业重启，只需确保作业配置显式允许（默认已开启，但建议明确配置避免歧义）：

@Bean
public Job myJob(JobRepository jobRepository, Step myStep) {
    return new JobBuilder("myJob", jobRepository)
            .start(myStep)
            .preventRestart(false) // 允许重启未完成的作业实例
            .build();
}

2. 用JobOperator触发重启 #

直接用JobLauncher调用会因重复参数报错，必须通过JobOperator指定中断的作业执行ID来重启：

@Autowired
private JobOperator jobOperator;

// 重启指定的中断作业
public void restartFailedJob(long failedJobExecutionId) throws Exception {
    jobOperator.restart(failedJobExecutionId);
}

这种方式会复用原JobInstance，自动从上次中断的Chunk位置继续执行（前提是Step的Reader/Writer实现了断点续跑逻辑）。

3. 验证断点续跑的测试流程 #

1. 模拟中断：在Chunk处理过程中手动抛出异常、kill进程，让作业处于unknown/started状态
2. 获取中断ID：从Spring Batch元数据表BATCH_JOB_EXECUTION中查询对应作业的JOB_EXECUTION_ID
3. 触发重启：调用上述restartFailedJob()方法传入该ID
4. 验证结果：
   • 查看BATCH_STEP_EXECUTION表的READ_COUNT/WRITE_COUNT，确认后续Chunk从中断时的计数开始
   • 检查业务数据，确保已处理的Chunk不会重复执行，未处理的从断点处继续

4. 常见遗漏点排查 #

• ItemReader未实现ItemStream：如果Reader没实现ItemStream接口并在update()方法中保存读取位置，重启后会从头读取，无法断点续跑
• JobParameters动态生成：若参数包含时间戳等动态值，每次都会生成新JobInstance，无法复用中断实例。需固定参数，或自定义JobParametersIncrementer仅在需要新实例时递增
• 元数据表异常：确保Spring Batch的元数据表（BATCH_JOB_EXECUTION、BATCH_STEP_EXECUTION等）能正常读写，这些表是记录断点状态的核心

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