aboutsummaryrefslogtreecommitdiff
path: root/ec2
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2013-04-17 18:49:18 -0700
committerPatrick Wendell <pwendell@gmail.com>2013-05-08 21:46:01 -0700
commit03b58378d06903c425c0e6d7c5d6be604f133d92 (patch)
treee56c0a9650c3e94a1d4e34508a4c219ec9e78e28 /ec2
parent73f8cd237e929ce6b0d80d1a5726b8fc67d7095f (diff)
downloadspark-03b58378d06903c425c0e6d7c5d6be604f133d92.tar.gz
spark-03b58378d06903c425c0e6d7c5d6be604f133d92.tar.bz2
spark-03b58378d06903c425c0e6d7c5d6be604f133d92.zip
Adding mapreduce module
Diffstat (limited to 'ec2')
-rwxr-xr-xec2/spark_ec2.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py
index 0ba5335bba..42e4fe9442 100755
--- a/ec2/spark_ec2.py
+++ b/ec2/spark_ec2.py
@@ -376,9 +376,10 @@ def setup_cluster(conn, master_nodes, slave_nodes, zoo_nodes, opts, deploy_ssh_k
ssh(master, opts, 'chmod 600 ~/.ssh/id_rsa')
if opts.cluster_type == "mesos":
- modules = ['ephemeral-hdfs', 'persistent-hdfs', 'mesos']
+ modules = ['ephemeral-hdfs', 'persistent-hdfs', 'mapreduce', 'mesos']
elif opts.cluster_type == "standalone":
- modules = ['ephemeral-hdfs', 'persistent-hdfs', 'spark-standalone']
+ modules = ['ephemeral-hdfs', 'persistent-hdfs', 'mapreduce',
+ 'spark-standalone']
if opts.ganglia:
modules.append('ganglia')