I'm having trouble with the self_contained example. When I run it, it divides the job between two machines in my cluster. One of the machines (the master) completes fine, but the other machine hangs in the map phase. In the stderr log, I get the message:
Traceback (most recent call last):
File "/mapred/local/taskTracker/distcache/...etc...", line 29, in <module>
from cv.mr import run_task
ImportError: No module named mr
Is it possible that the cv.tgz file either isn't getting expanded properly, or that main python file doesn't know where to find its local import files?
If you need any more info on this, please let me know.
Bob Gaimari
If you would like to refer to this comment somewhere else in this project, copy and paste the following link:
Hi,
I'm having trouble with the self_contained example. When I run it, it divides the job between two machines in my cluster. One of the machines (the master) completes fine, but the other machine hangs in the map phase. In the stderr log, I get the message:
Traceback (most recent call last):
File "/mapred/local/taskTracker/distcache/...etc...", line 29, in <module>
from cv.mr import run_task
ImportError: No module named mr
Is it possible that the cv.tgz file either isn't getting expanded properly, or that main python file doesn't know where to find its local import files?
If you need any more info on this, please let me know.
Hi,which version of Pydoop/Hadoop are you running?