Spring Batch应用：过滤旧未完成Job执行记录，避免重复触发报错

方法一：添加时间阈值过滤僵死记录 #

你当前的检查逻辑只判断了状态，但没考虑这类“僵尸”记录的时间特征——真正在运行的Job，last_updated时间肯定是近期的。可以给检查逻辑加一个时间阈值（比如30分钟，根据你的Job实际运行时长调整），超过这个时间的STARTED状态记录直接判定为僵死，不触发阻塞。

修改后的代码示例：

// 设置超时阈值，示例为30分钟
long timeoutMillis = 30 * 60 * 1000;
JobInstance lastJobInstance = jobExplorer.getLastJobInstance(job.getName());

if (lastJobInstance != null) {
    List<JobExecution> runningExecutions = jobExplorer.getJobExecutions(lastJobInstance);
    long currentTime = System.currentTimeMillis();

    for (JobExecution execution : runningExecutions) {
        BatchStatus status = execution.getStatus();
        long lastUpdatedTime = execution.getLastUpdated().getTime();
        // 同时满足状态为运行中且未超时，才判定为真正在运行
        if ((status == BatchStatus.STARTED || status == BatchStatus.STARTING) 
            && (currentTime - lastUpdatedTime) < timeoutMillis) {
            throw new IllegalStateException("Job is already running: " + job.getName());
        }
    }
}

方法二：手动/自动标记僵死记录为ABANDONED #

Spring Batch提供了JobOperator接口，可以将僵死的Job执行记录标记为ABANDONED状态，这样它就不会再被判定为运行中。

手动清理（一次性处理旧记录） #

如果只是处理这条历史僵死记录，可以直接调用abandon方法：

@Autowired
private JobOperator jobOperator;

// 传入僵死记录的job_execution_id，比如示例中的13
jobOperator.abandon(13L);

执行后，数据库里的那条记录status会变成ABANDONED，你的检查逻辑就会忽略它。

自动清理（启动前检查超时记录） #

可以在启动Job前，自动扫描所有状态为STARTED/STARTING且超时的记录，批量标记为ABANDONED：

long timeoutMillis = 30 * 60 * 1000;
long currentTime = System.currentTimeMillis();

// 获取该Job所有状态为运行中的执行记录
List<JobExecution> allRunningExecutions = jobExplorer.findRunningJobExecutions(job.getName());
for (JobExecution execution : allRunningExecutions) {
    if (currentTime - execution.getLastUpdated().getTime() > timeoutMillis) {
        jobOperator.abandon(execution.getId());
    }
}

// 再执行原来的运行检查逻辑
// ...

方法三：优化检查范围（检查所有Job实例的运行记录） #

你原来的代码只检查了最后一个Job实例的执行记录，其实可以直接获取该Job所有状态为运行中的记录，再结合时间过滤，写法更简洁：

long timeoutMillis = 30 * 60 * 1000;
long currentTime = System.currentTimeMillis();

// 获取该Job所有正在运行的执行记录
List<JobExecution> runningExecutions = jobExplorer.findRunningJobExecutions(job.getName());
for (JobExecution execution : runningExecutions) {
    if (currentTime - execution.getLastUpdated().getTime() < timeoutMillis) {
        throw new IllegalStateException("Job is already running: " + job.getName());
    }
}

补充：避免僵死记录产生的建议 #

这类记录通常是因为应用突然崩溃、进程被杀导致Spring Batch无法正常更新Job状态。可以做这些优化：

• 给Job配置合理的Step级别重试/恢复机制，避免异常直接导致进程终止
• 部署时使用容器化或进程管理工具，确保进程异常退出时能被感知
• 定期清理Batch元数据表中的废弃记录（比如自定义定时任务）

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