Spring 批量远程分区不工作

Spring Batch Remote partitioning not working

我们有一个使用 Spring Boot 2.5.2 的 Spring 批处理应用程序,其中批处理作业被部署为云任务。在使用远程分区时,我们注意到整个分区有效负载被发送到所有工作 JVM。

例如,如果我们的有效载荷是 1000 条记录,分区大小为 500,那么两个工作人员都将获得所有 1000 条记录,而不是每条 500 条记录。执行上下文似乎在 Master 中正确完成了划分,因为它使用前 500 条记录打印 partition0,使用接下来的 500 条记录打印 partition1。所以我们很惊讶为什么 Spring Batch 没有将有效负载相应地传递给工人。

如有任何帮助,我们将不胜感激。

可以使用 Spring Boot 2.1.1 和相应的较低版本的 Cloud、Deployer 和 Cloud 任务。