我创建了一个spring批处理作业，它从mongodb读取订单，并发出rest调用来上传它们。但是，即使mongoitemreader没有读取所有记录，批处理作业也会自动完成。
我正在维护一个现场批次processed:boolean on 订单收集。mongoitemreader读取{batchprocessed:{$ne:true}}的记录，因为我需要多次运行批处理作业，而不是一次又一次地处理相同的文档。
在orderwriter中，我将batchprocessed设置为true。

@Bean
@StepScope
public MongoItemReader<Order> orderReader() {
MongoItemReader<Order> reader = new MongoItemReader<>();
reader.setTemplate(mongoTempate);
HashMap<String,Sort.Direction> sortMap = new HashMap<>();
sortMap.put("_id",Direction.ASC);
reader.setSort(sortMap);
reader.setTargetType(Order.class);
reader.setQuery("{batchProcessed:{$ne:true}}");
return reader;
}

@Bean
public Step uploadOrdersStep(OrderItemProcessor processor)  {
return stepBuilderFactory.get("step1").<Order, Order>chunk(1)
.reader(orderReader()).processor(processor).writer(orderWriter).build();
}

@Bean
public Job orderUploadBatchJob(JobBuilderFactory factory, OrderItemProcessor processor) {
return factory.get("uploadOrder").flow(uploadOrdersStep(processor)).end().build();
}