(args)
| 68 | f.close() |
| 69 | |
| 70 | def write_mapred_site_xml(args): |
| 71 | doc, mapredsite = get_doc() |
| 72 | ip = 'hdfs://{name_node}:9001'.format(name_node=args.masters) |
| 73 | prop = write_property(doc, 'mapred.job.tracker', ip, False) |
| 74 | mapredsite.appendChild(prop) |
| 75 | |
| 76 | f = open(conf_path_prefix + 'mapred-site.xml', 'wb') |
| 77 | f.write(doc.toprettyxml(indent = '')) |
| 78 | f.close() |
| 79 | |
| 80 | def write_hadoop_env(): |
| 81 | f = open(conf_path_prefix + 'hadoop-env.sh', 'a') |
nothing calls this directly
no test coverage detected