Skip to content
Snippets Groups Projects
Commit d65d3dd8 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Fixing syntax error

parent 24777362
No related branches found
No related tags found
No related merge requests found
...@@ -160,7 +160,7 @@ def is_active(instance): ...@@ -160,7 +160,7 @@ def is_active(instance):
# Return correct versions of Spark and Shark, given the supplied spark version # Return correct versions of Spark and Shark, given the supplied spark version
def get_spark_shark_version(opts): def get_spark_shark_version(opts):
spark_shark_map = ["0.7.2", "0.7.0"] spark_shark_map = {"0.7.2": "0.7.0"}
version = opts.spark_version.replace("v", "") version = opts.spark_version.replace("v", "")
if version not in ["latest", "0.7.2"]: if version not in ["latest", "0.7.2"]:
print >> stderr, "Don't know about spark version: %s" % version print >> stderr, "Don't know about spark version: %s" % version
...@@ -463,7 +463,7 @@ def setup_standalone_cluster(master, slave_nodes, opts): ...@@ -463,7 +463,7 @@ def setup_standalone_cluster(master, slave_nodes, opts):
def setup_spark_cluster(master, opts): def setup_spark_cluster(master, opts):
(spark_v, shark_v) = get_spark_shark_version(opts) (spark_v, shark_v) = get_spark_shark_version(opts)
ssh(master, opts, "chmod u+x spark-ec2/setup.sh") ssh(master, opts, "chmod u+x spark-ec2/setup.sh")
ssh(master, opts, "spark-ec2/setup.sh %s %s" % (spark_v, shark_v))) ssh(master, opts, "spark-ec2/setup.sh %s %s" % (spark_v, shark_v))
if opts.cluster_type == "mesos": if opts.cluster_type == "mesos":
print "Mesos cluster started at http://%s:8080" % master print "Mesos cluster started at http://%s:8080" % master
elif opts.cluster_type == "standalone": elif opts.cluster_type == "standalone":
......
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