From f9e95ab52231493e99fd5c71d334e5b8a4eb852e Mon Sep 17 00:00:00 2001 From: Tianqi Chen Date: Fri, 5 Dec 2014 09:09:20 -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 af061360c..4990b62da 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 -reducer /bin/cat stdin %d %d stdout' % (args.hadoop_binary, args.hadoop_streaming_jar, args.input, args.output, args.mapper, 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, slave_args, args.nclusters, args.iterations) print cmd subprocess.check_call(cmd, shell = True)