Код выхода: 127 с Fabric2 при выполнении удаленной команды ssh. ⇐ Python

[Anonymous]

Я столкнулся со странным поведением командного модуля Fabric2. Эти команды работают просто великолепно:

Код: Выделить всё

connect = Connection(host=h, user=u ,connect_kwargs={"password":p})
connect.run('mkdir temp_streaming')
connect.put(m, "temp_streaming/mapper.py")
connect.put(r, "temp_streaming/reducer.py")

Но когда дело доходит до этого:

Код: Выделить всё

input_path = input("Please choose the input of your program (on your HDFS File System) ")
output_path = input("Please choose a name for your output folder ")

main_command = str('yarn jar '+ jar_path+' -files mapper.py,reducer.py -mapper temp_streaming/mapper.py -reducer temp_streaming/reducer.py -input '+ input_path + ' -output '+ output_path)

connect.run(main_command)

Я получаю эту ошибку, которую не могу понять:

Код: Выделить всё

bash: yarn: command not found
Traceback (most recent call last):
File "__main.py__", line 77, in 
main()
File "__main.py__", line 65, in main
RunMapReduce(mapper, reducer, jar_path)
File "__main.py__", line 46, in RunMapReduce
connect.run(main_command)
File "", line 2, in run
File "/usr/local/lib/python3.5/dist-packages/fabric2/connection.py", line 30, in opens
return method(self, *args, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/fabric2/connection.py", line 586, in run
return self._run(runner, command, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/invoke/context.py", line 100, in _run
return runner.run(command, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/invoke/runners.py", line 268, in run
return self._run_body(command, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/invoke/runners.py", line 401, in _run_body
raise UnexpectedExit(result)
invoke.exceptions.UnexpectedExit: Encountered a bad command exit code!

Command: 'yarn jar /home/hadoop/hadoop/share/hadoop/tools/lib/hadoop-streaming-2.8.4.jar -files mapper.py,reducer.py -mapper temp_streaming/mapper.py -reducer temp_streaming/reducer.py -input /books/kafka_metamorphosis.txt -output /test'

Exit code: 127

Stdout: already printed

Stderr: already printed

Это действует так, как будто удаленный сервер не знает команду yarn, хотя эта команда bash работает, когда я напрямую войдите на сервер с помощью ssh и запустите его. Мне кажется, что это связано с этой библиотекой, но с документацией я не смог решить свою проблему.

Подробнее здесь: https://stackoverflow.com/questions/505 ... sh-command