0 
<batch:job id="xyzJob" job-repository="jobRepository"
    incrementer="jobParametersIncrementerImpl" restartable="false">
    <batch:step id="feeStep">
        <batch:tasklet transaction-manager="transactionManager" allow-start-if-complete="true">
            <batch:chunk reader="xyzReader" processor="xyzProcessor"
                writer="xyzWriter" commit-interval="4" >
                <batch:streams>
                    <batch:stream ref="fileWriter"/>
                </batch:streams>
            </batch:chunk>
            <batch:listeners>
                <batch:listener ref="stepExecutionListener"/>
            </batch:listeners>
        </batch:tasklet>
    </batch:step>
    <batch:listeners>
        <batch:listener ref="xyzJobListener" />
    </batch:listeners>
</batch:job>

<bean id="xyzProcessor" class="com.batch.core.processor.XYZProcessor" scope="step">
    <property name="fundDAO" ref="fundDAO"/>
    <property name="loanDAO" ref="loanDAO"/>
    <property name="aumBlnceDAO" ref="aumBalanceDAO"/>
    ---
    --
</bean> 


<bean id="xyzWriter" class="org.springframework.batch.item.support.CompositeItemWriter">
        <property name="delegates">
            <list>
                <bean class="com.batch.core.writer.xyzWriter">
                        <property name="xyzDetailsDomain" ref="xyzDetailsDomain" />
                        <property name="xyzHistoryDomain" ref="xyzHistoryDomain"></property>
                </bean>
                <ref bean="fileWriter"/>
            </list>
        </property>
</bean>

<bean id="xyzReader" class="org.springframework.batch.item.database.JpaPagingItemReader" scope="step">  
   <property name="entityManagerFactory" ref="batchEntityManagerFactoryBean"/> 
   <property name="queryString"> 
      <value><![CDATA[
              SELECT pe, pap 
              FROM A pe, B pap 
              WHERE pap.userID =pe.userID and pe.status = 'E' 
              and pe.startDT <= '#{jobExecutionContext[previousQuarterEndDate]}' 
              and (pe.endDT is null 
              or pe.endDT > '#{jobExecutionContext[previousQuarterEndDate]}')]]>
       </value>
   </property>  
   <property name="pageSize" value="1000"/> 
   <property name="saveState" value="false" /> 
</bean>

当这个春季批次运行时，我注意到有时它在从表中读取数据时跳过了一些记录..这个问题不一致......但在 10 次中它可能会发生 1 次。

请帮我解决这个问题。提前致谢。！！

4

1 回答 1

0

JpaPagingItemReader不跳过记录。在您的情况下可能发生的情况是，在您的阅读器读取数据时添加了一些与您的搜索条件相对应的记录。这可能会导致错误的页面计算，并且某些项目似乎被跳过，但事实并非如此。

根据定义，批处理作业是作用于固定数据集的。如果您的查询在您的作业运行时返回一个固定的数据集，那么您的作业的每次运行都应该返回相同的页面。另一方面，如果另一个进程插入了您的查询可以返回的数据，那么您的问题可能会发生。

希望这可以帮助。

于 2018-11-07T19:52:45.477 回答