optimize StreamUtil and fix the LimitingExecutor

linkedin · Feb 16, 2024 · 5e76ff8 · 5e76ff8
1 parent 414d664
commit 5e76ff8
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/avro-builder/builder-spi/src/main/java/com/linkedin/avroutil1/builder/util/StreamUtil.java b/avro-builder/builder-spi/src/main/java/com/linkedin/avroutil1/builder/util/StreamUtil.java
@@ -132,7 +132,6 @@ private ParallelStreamCollector(Function<T, R> mapper, int parallelism, int batc
       }
       _mapper = mapper;
       _batchSize = batchSize;
-      //this.executor = new ForkJoinPool(parallelism);
       _executor = new LimitingExecutor(parallelism);
     }