IOError: [Errno 32] Broken pipe Oops, ssh subprocess exited with return code 255, restarting...

[Mohan Muppidi]

I have been using mrjob for past few weeks. I have a script thats working fine (Checked it yesterday evening), but today I got this error. Any suggestions ? Did anyone deal with this kind of error before ? 

Thanks,

MK

creating EMR connection (to elasticmapreduce.us-east-1.amazonaws.com)

Waiting 30.0 seconds...

  RUNNING for 2.7s

Unable to connect to resource manager

Waiting 30.0 seconds...

  RUNNING for 33.1s

Waiting 30.0 seconds...

creating EMR connection (to elasticmapreduce.us-east-1.amazonaws.com)

Traceback (most recent call last):

  File "scripts/run_mrjob.py", line 226, in <module>

    GeneralMRJob.run()

  File "/usr/local/lib/python2.7/site-packages/mrjob/job.py", line 429, in run

    mr_job.execute()

  File "/usr/local/lib/python2.7/site-packages/mrjob/job.py", line 447, in execute

    super(MRJob, self).execute()

  File "/usr/local/lib/python2.7/site-packages/mrjob/launch.py", line 158, in execute

    self.run_job()

  File "/usr/local/lib/python2.7/site-packages/mrjob/launch.py", line 238, in run_job

    self.stdout.flush()

IOError: [Errno 32] Broken pipe

  Oops, ssh subprocess exited with return code 255, restarting...

  Opening ssh tunnel to resource manager...