]> git.apps.os.sepia.ceph.com Git - teuthology.git/commitdiff
hadoop: use dict-to-conf converter
authorNoah Watkins <noahwatkins@gmail.com>
Mon, 23 Feb 2015 00:53:09 +0000 (16:53 -0800)
committerNoah Watkins <noahwatkins@gmail.com>
Mon, 23 Feb 2015 01:41:06 +0000 (17:41 -0800)
Signed-off-by: Noah Watkins <noahwatkins@gmail.com>
teuthology/task/hadoop.py

index 1d649711cbd61d5d84df2dd5fded0cf366b12362..4021c623aa7783c60ba4bd081be2b27413dbb458 100644 (file)
@@ -84,34 +84,17 @@ def get_mapred_site_data(ctx):
     return path, data_tmpl.format(namenode=host)
 
 def get_yarn_site_data(ctx):
-    data_tmpl = """
-<configuration>
-<property>
- <name>yarn.resourcemanager.resourcetracker.address</name>
- <value>{namenode}:8025</value>  
-</property>
-<property>
- <name>yarn.resourcemanager.scheduler.address</name>
- <value>{namenode}:8030</value>  
-</property>
-<property>
- <name>yarn.resourcemanager.address</name>
- <value>{namenode}:8050</value>  
-</property>
-<property>
- <name>yarn.resourcemanager.admin.address</name>
- <value>{namenode}:8041</value>  
-</property>
-<property>
-  <name>yarn.resourcemanager.hostname</name>
-  <value>{namenode}</value>
-</property>
-<property>
-  <name>yarn.nodemanager.aux-services</name>
-  <value>mapreduce_shuffle</value>
-</property>
-</configuration>
-"""
+    conf = {}
+    conf.update({
+        'yarn.resourcemanager.resourcetracker.address': '{namenode}:8025',
+        'yarn.resourcemanager.scheduler.address': '{namenode}:8030',
+        'yarn.resourcemanager.address': '{namenode}:8050',
+        'yarn.resourcemanager.admin.address': '{namenode}:8041',
+        'yarn.resourcemanager.hostname': '{namenode}',
+        'yarn.nodemanager.aux-services': 'mapreduce_shuffle',
+    })
+    data_tmpl = dict_to_hadoop_conf(conf)
+
     tempdir = teuthology.get_testdir(ctx)
     path = "{tdir}/hadoop/etc/hadoop/yarn-site.xml".format(tdir=tempdir)
     nodes = ctx.cluster.only(teuthology.is_type('hadoop.master'))