spring-batch - 可跳过的异常

Question

我正在尝试使用以下配置在批处理运行期间跳过所有异常:

<chunk reader="aaaFileReader" writer="aaaDBWriter"
                commit-interval="100" skip-limit="100000">
                <skippable-exception-classes>
                    <include class="java.lang.Exception" />
                    <exclude
                        class="org.springframework.jdbc.CannotGetJdbcConnectionException" />
                </skippable-exception-classes>

            </chunk>
            <listeners>
                <listener ref="aaabatchFailureListener" />
            </listeners>

然后我在我的监听器中处理异常。但是当 Spring Batch 实际上遇到异常时，它不会被跳过并且批处理运行以失败状态结束。实际异常是 FlatFileParse 异常。如何跳过 FlatFileParseException？这是日志:

:18:21.257 [main] DEBUG o.s.b.repeat.support.RepeatTemplate - Handling fatal exception explicitly (rethrowing first of 1): org.springframework.batch.core.step.skip.NonSkippableReadException: Non-skippable exception during read
15:18:21.257 [main] ERROR o.s.batch.core.step.AbstractStep - Encountered an error executing the step
org.springframework.batch.core.step.skip.NonSkippableReadException: Non-skippable exception during read
    at org.springframework.batch.core.step.item.FaultTolerantChunkProvider.read(FaultTolerantChunkProvider.java:81) ~[spring-batch-core.jar:na]
    at org.springframework.batch.core.step.item.SimpleChunkProvider$1.doInIteration(SimpleChunkProvider.java:106) ~[spring-batch-core.jar:na]
    at org.springframework.batch.repeat.support.RepeatTemplate.getNextResult(RepeatTemplate.java:367) ~[spring-batch-infrastructure.jar:na]
    at org.springframework.batch.repeat.support.RepeatTemplate.executeInternal(RepeatTemplate.java:215) ~[spring-batch-infr
Caused by: org.springframework.batch.item.file.FlatFileParseException: Parsing error at line: 5, input=[0254285458908060150983101150983         AK00055002035201401081044000804CK5861           00Twist,Oliver              AT&T                          20121208                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            ]
    at org.springframework.batch.

Answer 1

您可以在批处理作业配置中添加 FlatFileParseException 类，例如:

<batch:chunk reader="customImportReader" writer="customImporter" processor="customProcessor" commit-interval="1" skip-limit="10">
    <batch:skippable-exception-classes>
        <batch:include class="org.springframework.batch.item.file.FlatFileParseException" />
    </batch:skippable-exception-classes>
</batch:chunk>