Spring批处理-重复步骤消息

Question

我有一个spring批处理作业，预计将根据FIFO顺序处理'N'个作业ID。这个Spring批处理作业有5个步骤。
我们使用DECIDER来确定是否有更多的job-id。如果是，请转到第一步并运行该job-id的所有步骤。
我在spring-batch发出的日志中看到“duplicate step”消息，在第一个作业中的步骤（例如job-id=1)获得未知状态之前，该消息似乎没有问题。在这种情况下，第二个作业的相同步骤(job-id=2)无法启动，并声明“步骤处于未知状态，重新启动是危险的....”。是否有更好的方法来定义spring-batch作业来处理'n'个作业ID。

有一个表保存职务信息。每个作业在订单表中下订单。有可能需要在同一天处理两个工作。作业可以插入/更新具有相同修订（其他详细信息不同）的相同订单号，也可以插入/更新相同订单号的不同修订。批处理程序必须根据作业表中的success_time在FIFO模型中处理这些作业。

Job_Id      job_name    success_time
1           job1        2014-09-29 10:00:00
2           job2        2014-09-29 13:00:00

Order_id    order_number    order_revision  order_details   job_id
1           ABC             1               Test1            1
2           XYZ             1               Test2            1
3           ABC             2               Test1-Rev2       2

<batch:step id="abstractParentStep" abstract="true">
    <batch:tasklet>
        <batch:chunk commit-interval="100" />
    </batch:tasklet>
</batch:step>

<-- Using same reader and writer to simplify scenario depiction --> 
<batch:job id="OrderProcessingJob">
    <batch:step id="Collect-Statistics-From-Staging-Tables" next="Validate-Order-Mandatory-Fields" parent="abstractParentStep">
        <batch:tasklet>
            <batch:chunk reader="orderReader" writer="orderWriter" />
        </batch:tasklet>
    </batch:step>
    <batch:step id="Validate-Order-Mandatory-Fields" next="Validate-Item-Mandatory-Fields" parent="abstractParentStep">
        <batch:tasklet>
            <batch:chunk reader="orderReader" writer="orderWriter" />
        </batch:tasklet>
    </batch:step>
    <batch:step id="Validate-Item-Mandatory-Fields" next="decision" parent="abstractParentStep">
        <batch:tasklet>
            <batch:chunk reader="orderReader" writer="orderWriter" />
        </batch:tasklet>
    </batch:step>
    <batch:decision id="decision" decider="processMoreJobsDecider">
        <batch:next on="REPEAT" to="Validate-Order-Mandatory-Fields" />
        <batch:end on="COMPLETED" />
    </batch:decision>

</batch:job>

当第一个作业的步骤仍然处于未知状态，而第二个作业（因为decider决定还有一个job_id要处理）得到异常消息时，我们遇到了上面提到的异常。

Answer 1

您应该给每个步骤一个唯一的名称。如果使用分区，这将自动为您完成。

请参阅以下要点，文件partitionedsimple.groovy（只需下载文件并运行groovy )即可运行所有示例。在step1中，我们确定随后需要的步骤数（在那里硬编码为3)，并将其保存在作业上下文中（首先在步骤上下文中，然后进行升级）。我们创建一个分区步骤partitionedstep，它将启动3个步骤。它们的名称为repeatedstep: 。在分区中，我们还将一个名为PartitionIndex的键放在上下文中，这样我们就可以在实现重复步骤的tasklet中检索它。

然后，我们运行一个示例，在该示例中，当它处理第2项时，我们强制它失败。我们得到以下步骤执行：

Status is: FAILED
Step executions: 
  1: step1 
  2: partitionedStep FAILED
  4: repeatedStep:partition_1 
  5: repeatedStep:partition_2 FAILED
  3: repeatedStep:partition_3 

Status is: COMPLETED
Step executions: 
  6: partitionedStep 
  null: repeatedStep:partition_1 STARTING
  7: repeatedStep:partition_2 
  null: repeatedStep:partition_3 STARTING

Step executions: 
  1: step1 
  2: wrappingStep 
  3: repeated-1 
  4: wrappingStep FAILED
  5: repeated-2 FAILED

在第二次运行中：

Step executions: 
  6: wrappingStep 
  7: wrappingStep 
  8: repeated-2 
  9: wrappingStep 
  10: repeated-3