Spring Batch重启服务器后恢复JobRegistry并重启作业的问题

1. 解决JobRegistry为空导致的重启失败 #

内存型MapJobRegistry在服务器重启后会被清空，直接导致JobOperator找不到对应作业配置，抛出NoSuchJobException。可以通过以下方式解决：

• 自动注册Job Bean到JobRegistry：用Spring Batch提供的JobRegistryBeanPostProcessor，启动时自动把所有Job Bean注册到JobRegistry，无需手动维护：

  @Bean
  public JobRegistryBeanPostProcessor jobRegistryBeanPostProcessor(JobRegistry jobRegistry) {
      JobRegistryBeanPostProcessor postProcessor = new JobRegistryBeanPostProcessor();
      postProcessor.setJobRegistry(jobRegistry);
      return postProcessor;
  }
  

• 替换持久化JobRegistry实现：放弃MapJobRegistry，改用基于数据库或其他持久化存储的自定义JobRegistry，确保重启后作业配置不会丢失。
• 手动注册作业：如果作业不是Bean形式定义，启动后调用jobRegistry.register(job)手动注册，但这种方式可靠性不如BeanPostProcessor。

2. 多线程模式下作业假完成的修复 #

把Job改为Bean后能重启，但多线程模式下作业显示完成却没处理剩余数据，大概率是以下问题：

• 线程同步缺失：多线程Step没配置正确的同步机制，主线程提前判定作业完成，子线程还没执行完或没启动。要确保Step的taskExecutor配置正确，PartitionHandler的gridSize和线程池参数匹配。
• 状态更新不彻底：手动改数据库状态时，没把所有处于STARTED状态的Step都改成FAILED，导致重启后作业误以为部分Step已完成。必须同步更新batch_step_execution表中对应Job的所有STARTED状态记录。
• 线程池配置不合理：线程池核心/最大线程数太小，任务堆积但主线程没等所有任务结束就判定完成。调整线程池参数，比如：

  @Bean
  public TaskExecutor taskExecutor() {
      ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
      executor.setCorePoolSize(5);
      executor.setMaxPoolSize(10);
      executor.setQueueCapacity(20);
      executor.setWaitForTasksToCompleteOnShutdown(true);
      executor.setAwaitTerminationSeconds(30);
      return executor;
  }
  

• Partition重启逻辑异常：多线程Partition的重启需要每个Partition的执行状态都被正确重置，否则会被跳过。检查Partition配置，确保partitionHandler支持重启，且所有Partition的执行记录都更新为FAILED。

3. 崩溃后作业状态修改的正确步骤 #

服务器崩溃后，必须严格执行以下数据库操作，才能让作业被识别为可重启状态：

1. 更新作业执行表：

   UPDATE batch_job_execution
   SET status = 'FAILED', end_time = CURRENT_TIMESTAMP, exit_code = 'FAILED'
   WHERE job_execution_id = [你的jobExecutionId] AND status = 'STARTED';
   

2. 更新关联的步骤执行表：

   UPDATE batch_step_execution
   SET status = 'FAILED', end_time = CURRENT_TIMESTAMP, exit_code = 'FAILED'
   WHERE job_execution_id = [你的jobExecutionId] AND status = 'STARTED';
   

3. 用JobExplorer确认状态更新后，再调用JobOperator.restart(jobExecutionId)重启。

内容的提问来源于stack exchange，提问作者Shreyas Holla P