diff --git a/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/DifferentSourceSplitting.java b/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/DifferentSourceSplitting.java
index 3e133c21b1..9ad569df30 100644
--- a/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/DifferentSourceSplitting.java
+++ b/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/DifferentSourceSplitting.java
@@ -17,7 +17,7 @@ public class DifferentSourceSplitting {
     private static final List<Integer> linkedListOfNumbers = new LinkedList<>();
 
     static {
-        IntStream.rangeClosed(1, 100_000).forEach(i -> {
+        IntStream.rangeClosed(1, 1_000_000).forEach(i -> {
             arrayListOfNumbers.add(i);
             linkedListOfNumbers.add(i);
         });
diff --git a/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MemoryLocalityCosts.java b/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MemoryLocalityCosts.java
index 9bb6fcaa81..bc5cbf491b 100644
--- a/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MemoryLocalityCosts.java
+++ b/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MemoryLocalityCosts.java
@@ -11,11 +11,11 @@ import java.util.stream.IntStream;
 
 public class MemoryLocalityCosts {
 
-    private static final int[] intArray = new int[100_000];
-    private static final Integer[] integerArray = new Integer[100_000];
+    private static final int[] intArray = new int[1_000_000];
+    private static final Integer[] integerArray = new Integer[1_000_000];
 
     static {
-        IntStream.rangeClosed(1, 100_000).forEach(i -> {
+        IntStream.rangeClosed(1, 1_000_000).forEach(i -> {
             intArray[i-1] = i;
             integerArray[i-1] = i;
         });
diff --git a/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MergingCosts.java b/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MergingCosts.java
index 7266f6954f..a9919dbe72 100644
--- a/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MergingCosts.java
+++ b/core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/MergingCosts.java
@@ -16,7 +16,7 @@ public class MergingCosts {
     private static final List<Integer> arrayListOfNumbers = new ArrayList<>();
 
     static {
-        IntStream.rangeClosed(1, 100_000).forEach(i -> {
+        IntStream.rangeClosed(1, 1_000_000).forEach(i -> {
             arrayListOfNumbers.add(i);
         });
     }
@@ -39,14 +39,14 @@ public class MergingCosts {
     @BenchmarkMode(Mode.AverageTime)
     @OutputTimeUnit(TimeUnit.NANOSECONDS)
     public static void mergingCostsGroupingSequential() {
-        arrayListOfNumbers.stream().collect(Collectors.groupingBy(i -> i % 2 == 0));
+        arrayListOfNumbers.stream().collect(Collectors.toSet());
     }
 
     @Benchmark
     @BenchmarkMode(Mode.AverageTime)
     @OutputTimeUnit(TimeUnit.NANOSECONDS)
     public static void mergingCostsGroupingParallel() {
-        arrayListOfNumbers.stream().parallel().collect(Collectors.groupingBy(i -> i % 2 == 0));
+        arrayListOfNumbers.stream().parallel().collect(Collectors.toSet());
     }
 
 }