无法重新启动 Spring 批处理作业

Question

我有一个春季批处理作业，它读取、转换和写入 Oracle 数据库。我正在通过 CommandLineJobRunner 实用程序运行作业（使用由 maven shade 插件生成的 fat jar + 依赖项）；由于“已达到 Java 堆内存限制”，该作业随后中途失败，并且该作业未标记为 FAILED，但仍显示状态 STARTED。

我尝试使用相同的作业参数（如文档建议的那样）重新运行作业，但这给了我这个错误：

5:24:34.147 [main] ERROR o.s.b.c.l.s.CommandLineJobRunner - Job Terminated in error: A job execution for this job is already running: JobInstance: id=1, version=0, Job=[maskTableJob]

org.springframework.batch.core.repository.JobExecutionAlreadyRunningException：此作业的作业执行已在运行：JobInstance：id=1，version=0，Job=[maskTableJob] 在 org.springframework.batch.core.repository.support.SimpleJobRepository.createJobExecution(SimpleJobRepository.java:120) ~[maskng-batch-1.0-SNAPSHOT-executable.jar:1.0-SNAPSH

我尝试了各种方法（例如使用 -restart 参数手动将状态设置为 FAILED），但均无济于事。有什么我在这里遗漏的，因为我认为春季批处理的优点之一是它能够重新开始他们停止的工作......!!？

Answer 1

您应该知道的第一件事是 Joblauncher 不能用于重新启动已经运行的作业。 您收到“JobExecutionAlreadyRunningException”的原因是因为您传递的参数已经存在于数据库中，因此您会收到此异常。

在 spring batch 中，如果 job 以“FAILED”状态或“STOPPED”状态完成，则可以重新启动。

JobOperator 具有重新启动方法，可用于通过传递以“FAILED”状态或“STOPPED”状态完成的作业执行 ID 来重新启动失败的作业。

请注意，如果作业以“已完成”状态完成，则无法重新启动该作业。 在这种情况下，您必须使用新的作业参数提交新作业

如果您想手动将作业的状态设置为失败，请运行以下查询并使用 JobOperator.restart() 方法重新启动作业。

update batch_job_execution set status="FAILED", version=version+1 where job_instance_id=jobId;

事务管理处理不当可能是您的工作状态未更新为“FAILED”状态的一种可能原因。即使作业遇到运行时异常，请确保您的事务正在完成。