diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index 5e8b381a4d62f3869664832d1f13798870769717..ac309cc1f412c0c8fe1466ea2323ac52cd655830 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -636,7 +636,7 @@ def get_partition(total, num_partitions, current_partitions): def real_main(): (opts, action, cluster_name) = parse_args() try: - conn = ec2.connect_to_region(opts.region,aws_access_key_id="AKIAI2EGAQ7GYNL4LRAA", aws_secret_access_key="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") + conn = ec2.connect_to_region(opts.region) except Exception as e: print >> stderr, (e) sys.exit(1)