Re: Sending Apache avro serialized data to thrift server

[Avinash Dongre]

> Hi,
> I am trying to send avro serialized data to my thrift server. But when I
> try to de-serialized I get exception
> org.apache.avro.AvroRuntimeException: Malformed data. Length is negative:
> -51
>
> If I do the same operation in the same vm process everything works fine.
>
> Here is my small code.
>
> public static GenericRecord createContentNestedObject() throws Exception {
>     GenericRecord image1 = new GenericData.Record(IMAGE_SCHEMA);
>     image1.put("uri", new Utf8("http://javaone.com/keynote_large.jpg";));
>     image1.put("width", 0);
>     image1.put("height", 0);
>     image1.put("size", 2);
>     image1.put("title", new Utf8("Javaone Keynote"));
>     return image1;
>   }
>
>   // Helper Method to serialize the object from avro to bytebuffer
>   public static ByteBuffer serialize(GenericRecord content, Schema schema)
>       throws Exception {
>
>     ByteArrayOutputStream out = new ByteArrayOutputStream();
>     DatumWriter<GenericRecord> writer = new
> GenericDatumWriter<GenericRecord>(
>         schema);
>     // create Binary Encoder
>     EncoderFactory ef = new EncoderFactory();
>     BinaryEncoder be = ef.binaryEncoder(out, null);
>     writer.write(content, be);
>     be.flush();
>     out.close();
>
>     return ByteBuffer.wrap(out.toByteArray());
>   }
>
>   public static void main(String[] args) throws Exception {
>     try {
>       GenericRecord rd = createContentNestedObject();
>       bf = serialize(rd, IMAGE_SCHEMA);
>
>     } catch (Exception e) {
>       // TODO Auto-generated catch block
>       e.printStackTrace();
>     }
>
>     // Deserialization.
>     DatumReader<GenericRecord> reader = new
> GenericDatumReader<GenericRecord>(IMAGE_SCHEMA_1);
>     ByteArrayOutputStream out = new ByteArrayOutputStream();
>     try {
>       out.write(bf.array());
>     } catch (IOException e1) {
>       // TODO Auto-generated catch block
>       e1.printStackTrace();
>     }
>     BinaryDecoder decoder =
> DecoderFactory.get().binaryDecoder(out.toByteArray(), null);
>     try {
>       GenericRecord result = reader.read(null, decoder);
>       System.out.println("RESULT : " + result.toString());
>     } catch (IOException e) {
>       // TODO Auto-generated catch block
>       e.printStackTrace();
>     }
>
> This code works. When I send the bf to my thrift api , I am getting the
> error,
> my thrift api is simple which accept ByteBuffer and try to deserialize it.
>
> following is the code in the thrift server api
>
> DatumReader<GenericRecord> reader = new
> GenericDatumReader<GenericRecord>(IMAGE_SCHEMA_1);
>     ByteArrayOutputStream out = new ByteArrayOutputStream();
>     try {
>       out.write(bf.array());
>     } catch (IOException e1) {
>       // TODO Auto-generated catch block
>       e1.printStackTrace();
>     }
>     BinaryDecoder decoder =
> DecoderFactory.get().binaryDecoder(out.toByteArray(), null);
>     try {
>       GenericRecord result = reader.read(null, decoder);
>       System.out.println("RESULT : " + result.toString());
>     } catch (IOException e) {
>       // TODO Auto-generated catch block
>       e.printStackTrace();
>     }
>
>
>
> What is wrong here.
>
>
> Thanks
> Aviansh
>
>
>