diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-18 20:25:48 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-18 20:25:48 -0800 |
| commit | 03d847999e8c54684128573b94973544026081b2 (patch) | |
| tree | 185e6ae24ce09dece4f89e20e41fb5612954cc03 | |
| parent | 7151e1e4c8f4f764c54047ef82b988f887a0b9c7 (diff) | |
| parent | 6cba5a48b0bc1a90dd7a914a82636fcd33294822 (diff) | |
| download | spark-03d847999e8c54684128573b94973544026081b2.tar.gz spark-03d847999e8c54684128573b94973544026081b2.tar.bz2 spark-03d847999e8c54684128573b94973544026081b2.zip | |
Merge pull request #477 from shivaram/ganglia-port-change
Ganglia port change
| -rwxr-xr-x | ec2/spark_ec2.py | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index 7967bcac50..66b1faf2cd 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -179,7 +179,7 @@ def launch_cluster(conn, opts, cluster_name): if opts.cluster_type == "mesos": master_group.authorize('tcp', 38090, 38090, '0.0.0.0/0') if opts.ganglia: - master_group.authorize('tcp', 80, 80, '0.0.0.0/0') + master_group.authorize('tcp', 5080, 5080, '0.0.0.0/0') if slave_group.rules == []: # Group was just now created slave_group.authorize(src_group=master_group) slave_group.authorize(src_group=slave_group) @@ -415,6 +415,13 @@ def setup_standalone_cluster(master, slave_nodes, opts): def setup_spark_cluster(master, opts): ssh(master, opts, "chmod u+x spark-ec2/setup.sh") ssh(master, opts, "spark-ec2/setup.sh") + if opts.cluster_type == "mesos": + print "Mesos cluster started at http://%s:8080" % master + elif opts.cluster_type == "standalone": + print "Spark standalone cluster started at http://%s:8080" % master + + if opts.ganglia: + print "Ganglia started at http://%s:5080/ganglia" % master # Wait for a whole cluster (masters, slaves and ZooKeeper) to start up |