2017-04-05 3 views
2

Also ich versuche, meine mrjob aber immer den Fehler in der ersten Zeile auszuführen:fehlgeschlagen mrjob auf EMR importieren

ImportError: No module named mrjob.job 

I Job wie folgt bin starten:

python main.py --bootstrap-mrjob -v -r emr --emr-job-flow-id j-XXXXXXXXX ../data/data.txt 

Ich habe auch versucht, die folgende Zeile in meine mrjobs.conf hinzuzufügen:

Es funktioniert nicht. Also, wie es zu beheben?

EDIT: Eigentlich bekomme ich diesen Fehler nicht, wenn ich den Cluster von der Befehlszeile erstellen, aber wenn ich tring Skript auf dem bereits laufenden Cluster ausführen, schlägt es mit diesem Fehler fehl.

EDIT: so der eine mehr Unterschied, dass auf Cluster von der Kommandozeile erstellt ist, ich habe die folgenden Schritt

PENDING (cluster is BOOTSTRAPPING: Running bootstrap actions) 

aber auf bereits Cluster ausgeführt wird, ich habe es nicht

Antwort

0

Sie über muss explizit in mrjobs.conf übergeben werden: -c mrjobs.conf

+0

Ich tat, es hilft nicht – mirt

+0

Ich sah Ihre Bearbeitungen, wenn der Cluster bereits läuft dann müssen Sie Bootstrap mrjob nicht, wie es bereits beim Booten bootstrappte clus ter wurde erstellt. – Bill