title: Error when running python map reduce job using Hadoop streaming in Google Cloud Dataproc environment
body: <p>I want to run python map reduce job in Google Cloud Dataproc using hadoop streaming method. My map reduce python script, input file and job result output are located in Google Cloud Storage.</p>
  
  <p>I tried to run this command </p>
  
  <pre><code>hadoop jar /usr/lib/hadoop-mapreduce/hadoop-streaming.jar -file gs://bucket-name/intro_to_mapreduce/mapper_prod_cat.py -mapper gs://bucket-name/intro_to_mapreduce/mapper_prod_cat.py -file gs://bucket-name/intro_to_mapreduce/reducer_prod_cat.py -reducer gs://bucket-name/intro_to_mapreduce/reducer_prod_cat.py -input gs://bucket-name/intro_to_mapreduce/purchases.txt -output gs://bucket-name/intro_to_mapreduce/output_prod_cat
  </code></pre>
  
  <p>But I got this error output : </p>
  
  <blockquote>
    <p>File:
    /home/ramaadhitia/gs:/bucket-name/intro_to_mapreduce/mapper_prod_cat.py
    does not exist, or is not readable.</p>
    
    <p>Try -help for more information Streaming Command Failed!</p>
  </blockquote>
  
  <p>Is cloud connector not working in hadoop streaming? Is there any other way to run python map reduce job using hadoop streaming with python script and input file located in Google Cloud Storage ?</p>
  
  <p>Thank You</p>