IGNITE-1198 - Use correct number of executors.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/160ac38a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/160ac38a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/160ac38a Branch: refs/heads/ignite-1198 Commit: 160ac38a9b4f2f488ecaf12cc588b5047592e46f Parents: 1f32495 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Wed Aug 5 13:28:03 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Wed Aug 5 13:28:03 2015 -0700 ---------------------------------------------------------------------- .../src/main/scala/org/apache/ignite/spark/IgniteContext.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/160ac38a/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteContext.scala ---------------------------------------------------------------------- diff --git a/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteContext.scala b/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteContext.scala index 6e48017..cee71cf 100644 --- a/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteContext.scala +++ b/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteContext.scala @@ -47,7 +47,7 @@ class IgniteContext[K, V]( if (!client) { // Get required number of executors with default equals to number of available executors. val workers = sparkContext.getConf.getInt("spark.executor.instances", - sparkContext.getExecutorStorageStatus.length) + sparkContext.getExecutorStorageStatus.length - 1) if (workers <= 0) throw new IllegalStateException("No Spark executors found to start Ignite nodes.")
