From 981f69ff55b3f13bd3f65e32dfa2fd4859017b29 Mon Sep 17 00:00:00 2001 From: chenshuaihua Date: Sun, 11 Jan 2015 23:23:58 +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 76af354e3..bc794ba1b 100644 --- a/tracker/rabit_yarn.py +++ b/tracker/rabit_yarn.py @@ -79,7 +79,7 @@ def hadoop_streaming(nworker, slave_args): cmd += ' -D mapreduce.job.name=%s' % (args.jobname) cmd += ' -D mapreduce.map.cpu.vcores=%d' % (args.nthread) cmd += ' -D mapreduce.map.memory.mb=%d' % (args.memory_mb) - cmd += ' -D mapreduce.task.timeout=%d' % (args.timeout) +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()