File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
spring-batch-integration/src/main/java/org/springframework/batch/integration/async Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2006-2022 the original author or authors.
2
+ * Copyright 2006-2023 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
@@ -67,13 +67,13 @@ public void write(Chunk<? extends Future<T>> items) throws Exception {
67
67
T item = future .get ();
68
68
69
69
if (item != null ) {
70
- list .add (future . get () );
70
+ list .add (item );
71
71
}
72
72
}
73
73
catch (ExecutionException e ) {
74
74
Throwable cause = e .getCause ();
75
75
76
- if (cause != null && cause instanceof Exception ) {
76
+ if (cause instanceof Exception ) {
77
77
logger .debug ("An exception was thrown while processing an item" , e );
78
78
79
79
throw (Exception ) cause ;
You can’t perform that action at this time.
0 commit comments