IGNITE-3366: Hadoop: better configuration defaults.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1af9052c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1af9052c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1af9052c Branch: refs/heads/ignite-1232 Commit: 1af9052c73759939978fe256b7c9f3f4f57916c0 Parents: 5cc1f07 Author: vozerov-gridgain <[email protected]> Authored: Fri Jun 24 17:32:19 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Thu Jun 30 10:12:13 2016 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/configuration/HadoopConfiguration.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/1af9052c/modules/core/src/main/java/org/apache/ignite/configuration/HadoopConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/HadoopConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/HadoopConfiguration.java index 5f68c84..84014d6 100644 --- a/modules/core/src/main/java/org/apache/ignite/configuration/HadoopConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/configuration/HadoopConfiguration.java @@ -33,10 +33,10 @@ public class HadoopConfiguration { public static final boolean DFLT_EXTERNAL_EXECUTION = false; /** Default value for the max parallel tasks. */ - public static final int DFLT_MAX_PARALLEL_TASKS = Runtime.getRuntime().availableProcessors(); + public static final int DFLT_MAX_PARALLEL_TASKS = Runtime.getRuntime().availableProcessors() * 2; /** Default value for the max task queue size. */ - public static final int DFLT_MAX_TASK_QUEUE_SIZE = 1000; + public static final int DFLT_MAX_TASK_QUEUE_SIZE = 8192; /** Map reduce planner. */ private HadoopMapReducePlanner planner;
