Spring批处理步骤不执行

Question

我正在尝试修复Spring Batch中的一个问题，这个问题最近一直困扰着我们的系统。我们有一份工作，在大多数情况下都很好。下载和处理数据是一个多步骤的工作。

问题是有时工作会爆棚。也许我们试图连接到的服务器抛出了错误，或者我们在工作进行到一半时关闭了服务器。此时，下次我们的quartz调度程序尝试运行该作业时，它似乎什么也不做。以下是此作业定义的删节版本：

<batch:job id="job.download-stuff" restartable="true">
<batch:validator ref="downloadValidator"/>
<batch:step id="job.download-stuff.download">
    <batch:tasklet ref="salesChannelOrderDownloader" transaction-manager="transactionManager">
        <batch:transaction-attributes isolation="READ_UNCOMMITTED" propagation="NOT_SUPPORTED"/>
        <batch:listeners>
            <batch:listener ref="downloadListener"/>
            <batch:listener ref="loggingContextStepListener" />
        </batch:listeners>
    </batch:tasklet>
    <batch:next on="CONTINUE" to="job.download-stuff.process-stuff.step" />
    <batch:end on="*" />
</batch:step>
<batch:step id="job.download-stuff.process-stuff.step">
    ...
</batch:step>
<batch:listeners>
    <batch:listener ref="loggingContextJobListener"/>
</batch:listeners>

委婉地说，我是Spring Batch的新手，所以如果我遗漏了重要的细节，请原谅我。我已经设置了断点，并打开了日志记录，以了解我能做什么。

到目前为止，我在数据库中观察到的是，条目似乎不再写入BATCH_STEP_EXECUTION和BATCH_JOB_EXECUTION表。

对于未处于完成状态的作业，没有BATCH_JOB_EXECUTION条目，也没有BATCH_STEP_EXECUTION条目未处于完成状态

我仔细查看了作为批处理添加的downloadlistener：listener。以下是AfterStep的源代码：

@Override
@Transactional(propagation = Propagation.REQUIRES_NEW)
public ExitStatus afterStep(StepExecution stepExecution) {
    long runSeconds = TimeUnit.NANOSECONDS.toSeconds(System.nanoTime() - nanoStart);

    // If Success - we're good
    if (stepExecution.getStatus() == BatchStatus.COMPLETED) {
        Long endTs = stepExecution.getExecutionContext().getLong("toTime");
        Date toTime = new Date(endTs);
        handleSuccess(toTime, stepExecution.getWriteCount());
        return null;
    }

    // Otherwise - record errors
    List<Throwable> failures = stepExecution.getFailureExceptions();
    handleError(failures);
    return ExitStatus.FAILED;
}

我确认了返回exitstatus.failed行的html" target="_blank">执行，并且引发的异常被记录在FailureExceptions中。似乎一旦发生这种情况，BATCH_JOB_EXECUTION条目就处于完成状态（和exit_code)，而STEP_EXECUTION失败。

此时，BATCH_JOB_EXECUTION_PARAMS表中的条目仍然保留。我实际上尝试修改它们的KEY_NAME和value列的值，但这仍然不允许作业运行。只要有绑定到JOB_EXECUTION_ID的参数，属于相同BATCH_JOB_INSTANCE的另一个作业就不能运行。

Answer 1

JobParametersValidator，在您的示例中是DownloadValidatorbean在作业开始之前运行。

在您的情况下，传递作业的参数与“blobed up”JobInstance相同。然而，由于这项工作以戏剧性的方式失败，它可能没有被置于失败的状态。

您可以使用不同的参数运行作业（以获得新的作业实例），也可以尝试在重新启动之前将前一个步骤/作业的状态更新为BATCH_STEP_EXECUTION或BATCH_JOB_EXECUTION失败。

<batch:next on="CONTINUE" to="job.download-stuff.process-stuff.step" />
<batch:end on="*" />

首先，要非常小心地以*结尾。在您的方案中，它导致您完成作业（以“成功”），因为exitcode为failed。此外，成功步骤的默认exitcode是completed，而不是continue，所以要小心。

<!-- nothing to me indicates you'd get CONTINUE here, so I changed it -->
<batch:next on="COMPLETED" to="job.download-stuff.process-stuff.step" />

<!-- if you ever have reason to stop here -->
<batch:end on="END" /> 

<!-- always fail on anything unexpected -->
<batch:fail on="*" />