avro-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Scott Carey <scottca...@apache.org>
Subject Re: a possible bug in Avro MapReduce
Date Wed, 21 Mar 2012 02:35:01 GMT
Perhaps it is 
https://issues.apache.org/jira/browse/AVRO-1045

Are you creating a copy of the GenericRecord?

-Scott


On 3/19/12 3:34 PM, "ey-chih chow" <eychih@hotmail.com> wrote:

> Hi,
> 
> We got an Avro MapReduce job with the signature of the map function as
> follows:
> 
> 
> public void map(ByteBuffer input, AvroCollector<Pair<Utf8, GenericRecord>>
> collector, Reporter reporter) throws IOException;
> 
> 
> However, the position of the ByteBuffer input, i.e. input.position(), is
> always set to 0 when map() gets invoked.  With this, we can not extract data
> from input.  This is for the version of avro 1.5.4.  For the older versions of
> avro, input.position() is set to the end of the input data.  Is there anybody
> knows why this gets set to 0?  Or is this a bug?
> 
> Ey-Chih Chow
>        



Mime
View raw message