From ecf485c3cd31a475951b427eafbd1eaa1dfb71d5 Mon Sep 17 00:00:00 2001 From: CodingCat Date: Sun, 2 Mar 2014 21:56:27 -0500 Subject: [PATCH] clean vpc_id if the group was just now created --- ec2/spark_ec2.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index b0512ca891ad6..ff9f0a0b62ee6 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -228,6 +228,7 @@ def launch_cluster(conn, opts, cluster_name): master_group = get_or_make_group(conn, cluster_name + "-master") slave_group = get_or_make_group(conn, cluster_name + "-slaves") if master_group.rules == []: # Group was just now created + master_group.vpc_id = None master_group.authorize(src_group=master_group) master_group.authorize(src_group=slave_group) master_group.authorize('tcp', 22, 22, '0.0.0.0/0') @@ -240,6 +241,7 @@ def launch_cluster(conn, opts, cluster_name): if opts.ganglia: master_group.authorize('tcp', 5080, 5080, '0.0.0.0/0') if slave_group.rules == []: # Group was just now created + slave_group.vpc_id = None slave_group.authorize(src_group=master_group) slave_group.authorize(src_group=slave_group) slave_group.authorize('tcp', 22, 22, '0.0.0.0/0')