ストリーミング ジョブで、マッパーで実行可能ファイルを呼び出したいと考えています。それはこのようなものです
mapper.py
print os.popen('./binary').read()
コマンドは
$HADOOP_HOME/bin/hadoop fs -rmr $HADOOP_OUTPUT
$HADOOP_HOME/bin/hadoop streaming \
-D mapred.map.tasks=$MAP_NUM \
-D mapred.reduce.tasks=$RED_NUM \
-D mapred.job.map.capacity=500 \
-D mapred.map.capacity.per.tasktracker=1 \
-input $HADOOP_INPUT \
-output $HADOOP_OUTPUT \
-mapper mapper.py \
-file mapper.py binary\
しかし、その結果、バイナリ ファイルは実行されません。どうしてか分かりません。誰でも私を助けることができます