Spring Batch 3.0.10-使用TaskExecutor的并行步骤-不理解作业范围bean

Question

围绕这个主题似乎有很多问题，但我似乎找不到答案。如果这是个骗局，对不起！

我有一个有许多步骤的工作…在某一点上，我想并行地运行多个文件的项处理（读/验证/写）。在使这段代码并行之前，我同步运行了它，一切都很好。当我使用task-executor添加batch：split时，我现在得到的错误是：

2020-09-01 01:07:12,668[SimpleAsyncTaskExecutor-1]错误AbstractStep-在作业ATPRuleCombined org.springframework.beans.factory.beanCreationException中执行步骤loadBaseFareInfo时遇到错误：创建名为“ScopedTarget.AllAddScleanupProcessorForBaseFareInfo”的bean时出错：范围“job”对于当前线程不是活动的；如果您打算从单个对象引用这个bean，请考虑为它定义一个限定作用域的代理；嵌套异常是java.lang.IllegalStateException：没有可用于作业范围的上下文持有人

以下是相关代码：

        <batch:split id="loadMainTables" next="saveCacheNotification" task-executor="taskExecutor">
        <batch:flow>
            <batch:step id="loadBaseFareInfo">
                <batch:tasklet>
                    <batch:chunk reader="baseFareInfoGroupReader" processor="baseFareInfoGroupValidator"  writer="baseFareInfoGroupWriter"
                                 chunk-completion-policy="baseFareInfoCompletionPolicy">
                        <!--commit-interval="${baseFareInfo.commitInterval}"> -->
                        <!-- skip-policy="alwaysSkipPolicy"> -->
                        <batch:listeners>
                            <batch:listener ref="errorDataFileItemReadListener"/>
                            <batch:listener ref="springContextRepo"/>
                            <batch:listener ref="allAddsCleanupProcessorForBaseFareInfo"/>
                            <batch:listener ref="baseFareInfo.groupMetricListener"/>
                            <batch:listener ref="baseFareInfoGroupWriter"/>
                            <batch:listener ref="baseFareInfoGroupReader"/>
                            <batch:listener ref="baseFareInfoStepLocking"/>
                        </batch:listeners>
                        <batch:streams>
                            <batch:stream ref="baseFareInfoItemReader"/>
                        </batch:streams>
                    </batch:chunk>
                </batch:tasklet>
            </batch:step>
        </batch:flow>
        <batch:flow>
            <batch:step id="loadNegFareSecurity">
                <batch:tasklet>
                    <batch:chunk reader="negFareSecurityGroupReader" processor="negFareSecurityGroupValidator"  writer="negFareSecurityGroupWriter"
                                 chunk-completion-policy="negFareSecurityCompletionPolicy">
                        <!--commit-interval="${negFareSecurity.commitInterval}"> -->
                        <!-- skip-policy="alwaysSkipPolicy"> -->
                        <batch:listeners>
                            <batch:listener ref="errorDataFileItemReadListener"/>
                            <batch:listener ref="springContextRepo"/>
                            <batch:listener ref="allAddsCleanupProcessorForNegFareSecurity"/>
                            <batch:listener ref="negFareSecurity.groupMetricListener"/>
                            <batch:listener ref="negFareSecurityGroupWriter"/>
                            <batch:listener ref="negFareSecurityGroupReader"/>
                            <batch:listener ref="negFareSecurityStepLocking"/>
                        </batch:listeners>
                        <batch:streams>
                            <batch:stream ref="negFareSecurityItemReader"/>
                        </batch:streams>
                    </batch:chunk>
                </batch:tasklet>
            </batch:step>
        </batch:flow>
    </batch:split>

    <bean id="allAddsCleanupProcessorForBaseFareInfo"
      class="com.sabre.aircontent.batch2.rule.basefareinfo.cleanup.AllAddsCleanupProcessorForBaseFareInfo" scope="job">
    <property name="headerRepo" ref="headerRepo" />
    <property name="allAddsCleanupCursor" ref="hibernateCursorForBaseFareInfoAllAddsCleanup" />
    <property name="dao" ref="baseFareInfoDao" />
    <property name="cacheNotificationService" ref="cacheNotificationService"/>
    <property name="resourceName" value="#{jobParameters['job.resource']}" />
    <property name="entityName" value="${baseFareInfo.baseEntityName:#{null}}" />
    <property name="expireThresholdInPercent" value="${basefareinfo.allAdds.expireThresholdInPercent}"/>
    <property name="metricRepo" ref="baseFareInfo.metricRepo"/>
    <property name="jobStartTime"
              value="#{jobExplorer.getJobExecution(jobOperator.getExecutions(jobExecution.jobInstance.instanceId)[jobOperator.getExecutions(jobExecution.jobInstance.instanceId).size()-1]).startTime}"/>
    <property name="additionalCursorParamValues">
        <map>
            <entry key="vendor" value="${vendor}" />
        </map>
    </property>
</bean>

为什么不再识别allAddsCleanupProcessorForBaseFareInfo bean的作业范围？他们是解决这个问题的变通办法吗？

Answer 1

尝试…

 <bean id="allAddsCleanupProcessorForBaseFareInfo"
  class="com.sabre.aircontent.batch2.rule.basefareinfo.cleanup.AllAddsCleanupProcessorForBaseFareInfo" scope="step">
<property name="headerRepo" ref="headerRepo" />
<property name="allAddsCleanupCursor" ref="hibernateCursorForBaseFareInfoAllAddsCleanup" />
<property name="dao" ref="baseFareInfoDao" />
<property name="cacheNotificationService" ref="cacheNotificationService"/>
<property name="resourceName" value="#{jobParameters['job.resource']}" />
<property name="entityName" value="${baseFareInfo.baseEntityName:#{null}}" />
<property name="expireThresholdInPercent" value="${basefareinfo.allAdds.expireThresholdInPercent}"/>
<property name="metricRepo" ref="baseFareInfo.metricRepo"/>
<property name="jobStartTime"
          value="#{jobExplorer.getJobExecution(jobOperator.getExecutions(jobExecution.jobInstance.instanceId)[jobOperator.getExecutions(jobExecution.jobInstance.instanceId).size()-1]).startTime}"/>
<property name="additionalCursorParamValues">
    <map>
        <entry key="vendor" value="${vendor}" />
    </map>
</property>