Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Set the number of reducer failed when using typedbytes #7

Open
kitein9t opened this issue Jan 6, 2015 · 0 comments
Open

Set the number of reducer failed when using typedbytes #7

kitein9t opened this issue Jan 6, 2015 · 0 comments

Comments

@kitein9t
Copy link

kitein9t commented Jan 6, 2015

I am using Hadoop streaming with -io typedbytes and set mapred.reduce.tasks=2, but I finally got only one output file. And if I set mapred.reduce.tasks=0, then I got many output files. I am very confused.

SO my question is:
How to make mapred.reduce.tasks = num (num >1) config valid when I using -io typedbytes in streaming?

PS: my mapper's output is (key:string of python, value:array of numpy) .
And my .sh file:
hadoop jar $HADOOP_HOME/contrib/streaming/hadoop-streaming-1.2.1.jar
-D mapred.reduce.tasks=2

-fs local
-jt local
-io typedbytes
-inputformat org.apache.hadoop.mapred.SequenceFileAsBinaryInputFormat
-input FFT_SequenceFile
-output pinvoutput
-mapper 'pinvmap.py'
-file pinvmap.py

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant