FAQ
Hi!

Maybe I'm the only one ever used this :D.

Adding namedOutputs with AvroMultipleOutputs.addNamedOutput just adds them
to a static map which is of course not available on the cluster during
reduce execution. The unit tests pass though since the Instance of
AvroMultipleOutputs is the same in the Reducer as in the Job's main class,
so the added schemas there are present.
Fix would be to add the namedOutput schemas to the job configuration so
they can be parsed in the reducers. Example patch for the new mapreduce api
here:

https://gist.github.com/4677875

Have a nice evening,

Johannes

Search Discussions

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupuser @
categoriesavro
postedJan 30, '13 at 10:33p
activeJan 30, '13 at 10:33p
posts1
users1
websiteavro.apache.org
irc#avro

1 user in discussion

Johannes Schulte: 1 post

People

Translate

site design / logo © 2021 Grokbase