diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-28 14:50:54 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-28 14:50:54 -0700 |
| commit | 2a8bfbca00a1701bfe22f5b0967c2d95c088c277 (patch) | |
| tree | 27db372219b3a0f39133031ddfa86f6631a92ec8 /core/src/main | |
| parent | 4a138403efd876f177fe2ba43c1bd115b2858919 (diff) | |
| download | spark-2a8bfbca00a1701bfe22f5b0967c2d95c088c277.tar.gz spark-2a8bfbca00a1701bfe22f5b0967c2d95c088c277.tar.bz2 spark-2a8bfbca00a1701bfe22f5b0967c2d95c088c277.zip | |
Fixed a bug where isLocal was set to false when using local[K]
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/spark/SparkContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/SparkContext.scala b/core/src/main/scala/spark/SparkContext.scala index 758c42fa61..0643c367f0 100644 --- a/core/src/main/scala/spark/SparkContext.scala +++ b/core/src/main/scala/spark/SparkContext.scala @@ -69,7 +69,7 @@ class SparkContext( System.setProperty("spark.master.port", "0") } - private val isLocal = (master == "local" || master.startsWith("local\\[")) + private val isLocal = (master == "local" || master.startsWith("local[")) // Create the Spark execution environment (cache, map output tracker, etc) val env = SparkEnv.createFromSystemProperties( |