commit eae6dd0d1bc3ab9d5f1f212a74170bbd9f297d78
author Richard Eckart de Castilho <rec@apache.org> Mon Sep 20 10:49:58 2021 +0200
committer GitHub <noreply@github.com> Mon Sep 20 10:49:58 2021 +0200
tree fab41c745af033e3a5e99343671d795573ff5797
parent ea467f28f5be5ca4777c02865fafc0649dea684d
parent 4783ce9f0f244744ff33efe085ab56e6d87519f5

Merge pull request #157 from apache/bugfix/UIMA-6384-parallelism-argument-in-CpePipeline-is-ignored

[UIMA-6384] parallelism argument in CpePipeline is ignored

uimafit-cpe/src/main/java/org/apache/uima/fit/cpe/CpePipeline.java

diff --git a/uimafit-cpe/src/main/java/org/apache/uima/fit/cpe/CpePipeline.java b/uimafit-cpe/src/main/java/org/apache/uima/fit/cpe/CpePipeline.java
index 056cee2..be062b5 100644
--- a/uimafit-cpe/src/main/java/org/apache/uima/fit/cpe/CpePipeline.java
+++ b/uimafit-cpe/src/main/java/org/apache/uima/fit/cpe/CpePipeline.java
@@ -102,7 +102,7 @@
     CpeBuilder builder = new CpeBuilder();
     builder.setReader(readerDesc);
     builder.setAnalysisEngine(aaeDesc);
-    builder.setMaxProcessingUnitThreadCount(Runtime.getRuntime().availableProcessors() - 1);
+    builder.setMaxProcessingUnitThreadCount(parallelism);
 
     StatusCallbackListenerImpl status = new StatusCallbackListenerImpl();
     CollectionProcessingEngine engine = builder.createCpe(status);