diff options
| author | Florian Verhein <florian.verhein@gmail.com> | 2015-04-01 11:10:43 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-04-01 11:10:43 +0100 |
| commit | 412262346f6f48e641bd6899c703efa31aeaba1e (patch) | |
| tree | cc62cc0d3ecceb90c546cedaedb8fd490328c2bc /ec2 | |
| parent | ff1915e12edc4d23e0b4e88933429c2d3470f3d9 (diff) | |
| download | spark-412262346f6f48e641bd6899c703efa31aeaba1e.tar.gz spark-412262346f6f48e641bd6899c703efa31aeaba1e.tar.bz2 spark-412262346f6f48e641bd6899c703efa31aeaba1e.zip | |
[EC2] [SPARK-6600] Open ports in ec2/spark_ec2.py to allow HDFS NFS gateway
Authorizes incoming access to master on the ports required to use the hadoop hdfs nfs gateway from outside the cluster.
Author: Florian Verhein <florian.verhein@gmail.com>
Closes #5257 from florianverhein/master and squashes the following commits:
72a586a [Florian Verhein] [EC2] [SPARK-6600] initial impl
Diffstat (limited to 'ec2')
| -rwxr-xr-x | ec2/spark_ec2.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index c467cd08ed..5507a9c5a4 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -456,6 +456,13 @@ def launch_cluster(conn, opts, cluster_name): master_group.authorize('tcp', 50070, 50070, authorized_address) master_group.authorize('tcp', 60070, 60070, authorized_address) master_group.authorize('tcp', 4040, 4045, authorized_address) + # HDFS NFS gateway requires 111,2049,4242 for tcp & udp + master_group.authorize('tcp', 111, 111, authorized_address) + master_group.authorize('udp', 111, 111, authorized_address) + master_group.authorize('tcp', 2049, 2049, authorized_address) + master_group.authorize('udp', 2049, 2049, authorized_address) + master_group.authorize('tcp', 4242, 4242, authorized_address) + master_group.authorize('udp', 4242, 4242, authorized_address) if opts.ganglia: master_group.authorize('tcp', 5080, 5080, authorized_address) if slave_group.rules == []: # Group was just now created |