重新启动不可重新启动的作业的新实例

Question

我已经定义了一个带有参数 restart="false" 的 Spring-Batch 作业，因为我不希望再次启动相同的作业实例。

<batch:job id="myJob" restartable="false">
    <batch:step id="myStep">
        <batch:tasklet>
            ...
        </batch:tasklet>
    </batch:step>
</batch:job>

该作业在另外两个更高级别的作业中被引用：

<batch:job id="hightLevelJob1" restartable="false">
    <batch:step id="myHighLevelJob1Step1" next="...">
        <batch:job ref="myJob"/>
    </batch:step>
    ...
</batch:job>

<batch:job id="hightLevelJob2" restartable="false">
    <batch:step id="myHighLevelJob2Step1" next="...">
        <batch:job ref="myJob"/>
    </batch:step>
    ...
</batch:job>

我现在有两个 JUnit-Test，每个都启动一个高级作业：

@Autowired
private JobOperator jobOperator;

@Test
public void testHighLevelJob1() throws JobExecutionException {
    final Long executionId = jobOperator.startNextInstance("myHighLevelJob1");
    ...
}

@Test
public void testHighLevelJob2() throws JobExecutionException {
    final Long executionId = jobOperator.startNextInstance("myHighLevelJob2");
    ...
}

第一个测试运行良好，而第二个则抛出 JobRestartException：

JobInstance already exists and is not restartable

我正在使用 jobOperator.startNextInstance() 所以它创建了一个 new 作业。但是，这似乎只适用于启动的高级作业。看起来 Spring-Batch 试图重用引用的作业。

如何将作业配置为每次都创建引用作业的新实例？

Answer 1

您需要JobParametersIncrementer 才能使其工作，因为 startNextInstance 的 javadocs 明确指出：“在 JobInstance 的序列中启动下一个 JobInstance，该 JobInstance 由附加到指定作业的 JobParametersIncrementer 确定”

JobParametersIncrementer 可帮助您增加新参数并将其放入 JobParameters 中，从而可以启动新的 Job 实例。

修改您的作业定义 bean 并添加增量器

<batch:job id="myJob" restartable="false" incrementer="incrementer">
    <batch:step id="myStep">
        <batch:tasklet>
            ...
        </batch:tasklet>
    </batch:step>
</batch:job>

并用一个简单的增量器实现 JobParametersIncrementer 类

<bean id="incrementer"
        class="com...TrivialJobParametersIncrementer" />

您可以在春季批处理管理示例中找到示例 TrivialJobParametersIncrementer。