Spring Batch分区，如何在任何分区步骤抛出异常时停止作业

Question

我正在运行一个带有分区步骤的Spring批处理作业，如果其中一个分区失败或抛出异常，我需要立即停止作业，如何停止作业，一旦任何一个分区步骤抛出异常，因为目前其他分区步骤一直运行到结束，在它们完成后，作业停止，返回代码不成功。

代码：：stepBuilderFactory.get（“masterStep”）.AllowStartifComplete（true）.Partitioner（multithreadedPartitionerStep）.Partitioner（“multithreadedPartitionerStep”,extractJobPartitioner）.gridSize（gridSize）.taskExecutor（taskExecutor）.build（）；

Answer 1

如果我理解正确的话，您希望Spring批处理作业根据您的步骤输出实现某种行为。

正如上面@Jim提到的，向我们展示您的分区处理程序。

第一件事第一份工作就是一份工作。它由步骤组成（分区的可能是）。如果步骤的任何状态变得陈旧，它也会反映在作业上（用一般术语来说）

另外，我想现在您可能已经转到了Spring Batch的更新版本。幸运的是，在4.x世界中，除了常规流之外，您还有三种选择。

1. 以一步结束
2. 步骤失败
3. 在给定步骤停止作业

参考连杆Spring导轨

@Bean
public Job job() {
        return this.jobBuilderFactory.get("job")
                                .start(step1())
                                .next(step2())
                                .on("FAILED").end()
                                .from(step2()).on("*").to(step3())
                                .end()
                                .build();
}

@Bean
public Job job() {
        return this.jobBuilderFactory.get("job")
                        .start(step1())
                        .next(step2()).on("FAILED").fail()
                        .from(step2()).on("*").to(step3())
                        .end()
                        .build();
}

和

在下面的场景中，如果step1以complete/failed/whather结束，那么作业将停止。一旦重新启动，执行将在步骤2开始。

@Bean
public Job job() {
        return this.jobBuilderFactory.get("job")
                        .start(step1()).on("COMPLETED").stopAndRestart(step2())
                        .end()
                        .build();
}

在此分区步骤中，如果在任何csv中发现任何不正确数量的字段，将正确报告。这里asynctaskexecutor和threadpooltaskexecutor用于分区步骤。

希望它能有所帮助，并以某种方式适合您的场景。