Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix output chunk end property in ChunkProcessor implementations

Browse Source 
Resolves #4560
This commit is contained in:
Mustafa Yanar
2024-03-04 22:07:58 +03:00
committed by Mahmoud Ben Hassine
parent e785391915
commit a4a8ab7aaa
5 changed files with 41 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-batch-core/src/main/java/org/springframework/batch/core/step/item/FaultTolerantChunkProcessor.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2006-2023 the original author or authors.
* Copyright 2006-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -306,7 +306,9 @@ public class FaultTolerantChunkProcessor<I, O> extends SimpleChunkProcessor<I, O
break;
}
}
if (inputs.isEnd()) {
outputs.setEnd();
}
return outputs;
}

5
spring-batch-core/src/main/java/org/springframework/batch/core/step/item/SimpleChunkProcessor.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2006-2022 the original author or authors.
* Copyright 2006-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -340,6 +340,9 @@ public class SimpleChunkProcessor<I, O> implements ChunkProcessor<I>, Initializi
iterator.remove();
}
}
if (inputs.isEnd()) {
outputs.setEnd();
}
return outputs;
}