Skip to content
Snippets Groups Projects
Commit 886183e5 authored by Denny's avatar Denny
Browse files

Renamed spark-cluster to spark-local.

parent babbca0a
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
......@@ -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 = {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment