《BAT》专题

摘要：即使读取器/处理器/写入器成功，作业也会重新启动/重试。 我的步骤定义如下： 日志：

选项2:(a)创建内部带有SalesReader的DiscountReader（ItemReader方法中的ItemReader）-它为每个正在读取的DiscountObj调用SalesReader。(b)创建SalesWriter将SalesReader获取的日期写入数据库。 在任何情况下，由SalesReader执行的查询的参数都是动态的，因为它必须从当前的DiscountObJ中提取。这是仅

我正在做一个Spring批处理工作，它包含几个步骤（超过10个）。 谢谢你的回答。

我在生产中有10个大文件，我们需要从文件中读取每一行，将逗号分隔的值转换为某个值对象，并将其发送到JMS队列，还需要插入数据库中的3个不同的表中 如果我们取10个文件，我们将有3300万行。我们使用spring batch（MultiResourceItemReader）读取earch行，并使用write将其写入db，同时将其发送到JMS。它大约需要25个小时才能完成所有。 为了提高性能，我们考虑

任何建议都将不胜感激。谢谢

我使用spring批处理，其中步骤1是从数据库读写到列表，然后有步骤2从阅读器从列表读写到数据库，处理和写到数据库，步骤3将从列表读写，处理和写到数据库。

我的批处理作业不处理所有已读记录。 完成作业后，Spring批处理日志中读取了198282条记录，但在处理器中我有一条日志，在开始处理之前只记录了196503条，但有时，处理器处理了所有的记录。 步进 Spring启动版本:2.0.1

我在java配置中使用spring批处理。（批处理-核心3） 帮我PLZ。

我不擅长英语。如果有奇怪的句子，请指出来。 我有个问题。这就是如何实现CSV文件和数据库两个输入的ItemReader。Spring Batch有JDBCursorItemReader和FlatFileItemReader，但是每个类只使用一个输入项。我想要实现使用项目阅读器或其他类的两个输入。这不应该由Spring批量实施吗？如果不好，所以我想另一种手段。即由ItemProcessor或Item

我正试图找出这两种设置之间的区别。大小和缓冲区。Kafka制作人的记忆。 据我所知。大小：这是可以发送的批次的最大大小。 文档描述了缓冲区。memory as：生产者可以用来缓冲等待发送的记录的内存字节。 我不明白这两者之间的区别。有人能解释一下吗？ 谢啦

我试图用嵌入式tomcat运行一个web应用程序，包括许多spring批处理作业和spring批处理管理。然而，当我试图运行生成的fat jar时，我得到了以下错误，spring batch或boot团队的任何人都可以帮忙吗： 添加更多信息：spring Boot版本:1.1.9。从spring.io父pom版本1.0.3发布。版本我尝试从STS以及使用mvn spring-boot：run运行它

我使用这个示例作为spring batch应用程序的起点，使用远程分块：https://github.com/benas/spring-batch-remote-chunking-sample/blob/master/src/main/java/io/github/benas/masterconfiguration.java在这个示例中，我添加了自定义的读取器/写入器，但没有更改任何配置。这个例子

有一个简单的变通方法，在作业开始时清理MasterChunkReplelies队列通道，但我不确定它是否正确... 你能澄清一下吗？

我在Tasklet中编写了一个业务逻辑，在该逻辑中，我向外部Systema的队列之一发送一条消息，然后使用operator.stop（）方法停止作业（有时响应来得很晚，所以我通过停止spring批处理作业来释放系统资源）。 一旦收到来自systemA的回复，我需要再次从上次完成的作业重新启动作业。 这就是我在tasklet中所做的。 我现在面临的问题是，当消息被发送到systemA队列时，我立即得

我是Spring批处理的新手，我想找到使用用例的完美方法，如下所示： 我有多个csv文件，我想把它们存储在内存（作为集合存储...即列表地图），然后我想在我的逻辑业务的下一步/作业中使用/引用它们。 让我们举一个例子，一个对象XX和一个ItemWriter一起存储在地图上。 对象XX模型 对象X的itemReader 目标作者 正如你可以看到所有的记录都存储在地图与itemWriter，我做了一个