From e05098cacbb8b8a3c0db588ceecba856eda5c56f Mon Sep 17 00:00:00 2001 From: Tianqi Chen Date: Fri, 5 Dec 2014 09:10:26 -0800 Subject: [PATCH] Update submit_job_hadoop.py --- submit_job_hadoop.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/submit_job_hadoop.py b/submit_job_hadoop.py index 4990b62da..eef480fa2 100755 --- a/submit_job_hadoop.py +++ b/submit_job_hadoop.py @@ -12,7 +12,7 @@ from threading import Thread def hadoop_streaming(nslaves, slave_args): - cmd = '%s jar %s -input %s -output %s -mapper \"%s %s\" -reducer /bin/cat stdin %d %d stdout' % (args.hadoop_binary, args.hadoop_streaming_jar, args.input, args.output, args.mapper, slave_args, args.nclusters, args.iterations) + cmd = '%s jar %s -input %s -output %s -mapper \"%s %s\" -reducer /bin/cat stdin %d %d stdout' % (args.hadoop_binary, args.hadoop_streaming_jar, args.input, args.output, args.mapper, ' '.join(slave_args), args.nclusters, args.iterations) print cmd subprocess.check_call(cmd, shell = True)