You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2015/08/05 22:29:11 UTC
incubator-ignite git commit: IGNITE-1198 - Use correct number of
executors.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-1198 160ac38a9 -> 990821548
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/99082154
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/99082154
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/99082154
Branch: refs/heads/ignite-1198
Commit: 9908215481855451e0c2306da70c37559a5d6f9f
Parents: 160ac38
Author: Alexey Goncharuk <ag...@gridgain.com>
Authored: Wed Aug 5 13:29:08 2015 -0700
Committer: Alexey Goncharuk <ag...@gridgain.com>
Committed: Wed Aug 5 13:29:08 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/99082154/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 cee71cf..6e48017 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 - 1)
+ sparkContext.getExecutorStorageStatus.length)
if (workers <= 0)
throw new IllegalStateException("No Spark executors found to start Ignite nodes.")