diff --git a/src/main/java/org/warp/commonutils/batch/ParallelUtils.java b/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
index 6570988..de52de2 100644
--- a/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
+++ b/src/main/java/org/warp/commonutils/batch/ParallelUtils.java
@@ -111,6 +111,7 @@ public class ParallelUtils {
 								consumer.accept((K) keysCopy[i], (V) valuesCopy[i]);
 							} catch (Exception ex) {
 								firstExceptionReference.compareAndSet(null, new CompletionException(ex));
+								break;
 							}
 						}
 					});