From 5e843cfbbd58a9d77d837d6f5711b2a30a9fa89a Mon Sep 17 00:00:00 2001 From: chenshuaihua Date: Sun, 11 Jan 2015 23:22:26 +0800 Subject: [PATCH] yarn script --- tracker/rabit_yarn.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tracker/rabit_yarn.py b/tracker/rabit_yarn.py index 9922b55d2..76af354e3 100644 --- a/tracker/rabit_yarn.py +++ b/tracker/rabit_yarn.py @@ -78,8 +78,8 @@ def hadoop_streaming(nworker, slave_args): cmd = '%s jar %s -D mapreduce.job.maps=%d' % (args.hadoop_binary, args.hadoop_streaming_jar, nworker) cmd += ' -D mapreduce.job.name=%s' % (args.jobname) cmd += ' -D mapreduce.map.cpu.vcores=%d' % (args.nthread) - cmd += ' -D mapreduce.task.timeout=%d' % (args.timeout) cmd += ' -D mapreduce.map.memory.mb=%d' % (args.memory_mb) + cmd += ' -D mapreduce.task.timeout=%d' % (args.timeout) cmd += ' -input %s -output %s' % (args.input, args.output) cmd += ' -mapper \"%s\" -reducer \"/bin/cat\" ' % (' '.join(args.command + slave_args)) fset = set()