diff --git a/core/src/main/scala/spark/SparkContext.scala b/core/src/main/scala/spark/SparkContext.scala index e24f4be5a45ac776f5dad766828215adf0655cc9..a3a1000d3030b85363495f06defbc5ee523a0ebb 100644 --- a/core/src/main/scala/spark/SparkContext.scala +++ b/core/src/main/scala/spark/SparkContext.scala @@ -84,7 +84,7 @@ class SparkContext( // Regular expression for local[N, maxRetries], used in tests with failing tasks val LOCAL_N_FAILURES_REGEX = """local\[([0-9]+),([0-9]+)\]""".r // Regular expression for simulating a Spark cluster of [N, cores, memory] locally - val SPARK_LOCALCLUSTER_REGEX = """spark-cluster\[([0-9]+)\,([0-9]+),([0-9]+)]""".r + val SPARK_LOCALCLUSTER_REGEX = """local-cluster\[([0-9]+)\,([0-9]+),([0-9]+)]""".r // Regular expression for connecting to Spark deploy clusters val SPARK_REGEX = """(spark://.*)""".r diff --git a/core/src/main/scala/spark/deploy/LocalSparkCluster.scala b/core/src/main/scala/spark/deploy/LocalSparkCluster.scala index 4f37cd5f83c505ac9f5e2ab0680274a1ed106e29..5c535ed502cb6c392dc825ebafc13e7e824067a5 100644 --- a/core/src/main/scala/spark/deploy/LocalSparkCluster.scala +++ b/core/src/main/scala/spark/deploy/LocalSparkCluster.scala @@ -19,7 +19,7 @@ class LocalSparkCluster(numSlaves : Int, coresPerSlave : Int, var masterPort : Int = _ var masterUrl : String = _ - val slaveActors = ArrayBuffer[ActorRef]() + val slaveActors = ArrayBuffer[ActorRef]() def start() : String = {