This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a commit to branch fix_combine_node_issue
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 867dd66facea5ec246438d6bdcac8f759dde9617
Author: Xiang Fu <fx19880...@gmail.com>
AuthorDate: Sat Aug 10 02:50:46 2019 -0700
Make MAX_PLAN_THREADS >= 1
---
.../src/main/java/org/apache/pinot/core/plan/CombinePlanNode.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/plan/CombinePlanNode.java
b/pinot-core/src/main/java/org/apache/pinot/core/plan/CombinePlanNode.java
index c0cce5a..3cf8da7 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/plan/CombinePlanNode.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/plan/CombinePlanNode.java
@@ -39,7 +39,8 @@ import org.slf4j.LoggerFactory;
public class CombinePlanNode implements PlanNode {
private static final Logger LOGGER =
LoggerFactory.getLogger(CombinePlanNode.class);
- private static final int MAX_PLAN_THREADS = Math.min(10, (int)
(Runtime.getRuntime().availableProcessors() * .5));
+ private static final int MAX_PLAN_THREADS =
+ Math.max(1, Math.min(10, (int)
(Runtime.getRuntime().availableProcessors() * .5)));
private static final int MIN_TASKS_PER_THREAD = 10;
private static final int TIME_OUT_IN_MILLISECONDS_FOR_PARALLEL_RUN = 10_000;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
