From 491716c418f5effcd4b0aeb7b1c7630f8788dc95 Mon Sep 17 00:00:00 2001 From: tqchen Date: Mon, 29 Dec 2014 06:21:34 -0800 Subject: [PATCH] chg --- tracker/rabit_hadoop.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tracker/rabit_hadoop.py b/tracker/rabit_hadoop.py index 7bc855ec8..977df254c 100755 --- a/tracker/rabit_hadoop.py +++ b/tracker/rabit_hadoop.py @@ -19,8 +19,10 @@ hadoop_home = os.getenv('HADOOP_HOME') if hadoop_home != None: if hadoop_binary == None: hadoop_binary = hadoop_home + '/bin/hadoop' + assert os.path.exists(hadoop_binary), "HADDOP_HOME does not contain the hadoop binary" if hadoop_streaming_jar == None: - hadoop_streaming_jar = hadoop_home + '/bin/hadoop' + hadoop_streaming_jar = hadoop_home + '/lib/hadoop-streaming.har' + assert os.path.exists(hadoop_streaming_jar), "HADDOP_HOME does not contain the haddop streaming jar" if hadoop_binary == None or hadoop_streaming_jar == None: print 'Warning: Cannot auto-detect path to hadoop and streaming jar, need to set them via arguments -hs and -hb'