Spring Batch：如何将已启动但未运行的Job状态设为FAILED

当服务器崩溃或进程被强制终止（如kill -9）时，Spring Batch的JobRepository无法感知Job已停止，导致Job状态停留在STARTED。根据官方文档要求，需手动将状态改为FAILED（仅当Job可重启且重启数据有效时），但JobOperator未提供直接的fail方法，可通过以下两种方式实现：

方法一：直接调用JobRepository API修改状态 #

JobOperator的底层依赖是JobRepository，可直接注入JobRepository来更新JobExecution的状态：

import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;

@Component
public class JobStatusManager {

    private final JobRepository jobRepository;

    public JobStatusManager(JobRepository jobRepository) {
        this.jobRepository = jobRepository;
    }

    // 将指定ID的JobExecution标记为FAILED
    public void markAsFailed(Long jobExecutionId) {
        JobExecution jobExecution = jobRepository.getJobExecution(jobExecutionId);
        if (jobExecution != null && jobExecution.getStatus() == BatchStatus.STARTED) {
            jobExecution.setStatus(BatchStatus.FAILED);
            jobExecution.setEndTime(LocalDateTime.now());
            // 可选：添加失败原因
            jobExecution.addFailureException(new IllegalStateException("服务器崩溃导致Job终止"));
            jobRepository.update(jobExecution);
        }
    }
}

关键注意点：

• 执行前必须确认Job进程已完全终止，这是文档明确要求的业务决策，不可自动化执行。
• 仅在Job可重启、重启数据未损坏时使用此方法，否则应调用JobOperator.abandon()将状态改为ABANDONED。
• 建议在事务方法内执行此操作，避免数据不一致。

方法二：自定义JobOperator扩展fail方法 #

若希望通过JobOperator风格的API操作，可继承SimpleJobOperator并添加自定义的fail方法：

import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.launch.NoSuchJobExecutionException;
import org.springframework.batch.core.launch.support.SimpleJobOperator;

import java.time.LocalDateTime;

public class CustomJobOperator extends SimpleJobOperator {

    public void fail(Long jobExecutionId) throws NoSuchJobExecutionException {
        JobExecution jobExecution = getJobExecution(jobExecutionId);
        if (jobExecution != null && jobExecution.getStatus() == BatchStatus.STARTED) {
            jobExecution.setStatus(BatchStatus.FAILED);
            jobExecution.setEndTime(LocalDateTime.now());
            jobExecution.addFailureException(new IllegalStateException("服务器崩溃导致Job终止"));
            getJobRepository().update(jobExecution);
        }
    }
}

之后在Spring配置中替换默认的JobOperator为自定义实现即可。

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