Hi,

Greetings,
 some one can help me on following Exception.

Thanks
parmeswara reddy.m

Exception is:

2012-11-06 01:34:43,847 (New I/O server boss #1 ([id: 0x5076e8a7,
/127.0.0.1:33334])) [INFO -
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:141)]
[id: 0x7f328c7a, /127.0.0.1:57026 => /127.0.0.1:33334] OPEN
2012-11-06 01:34:43,849 (New I/O server worker #1-1) [INFO -
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:141)]
[id: 0x7f328c7a, /127.0.0.1:57026 => /127.0.0.1:33334] BOUND: /
127.0.0.1:33334
2012-11-06 01:34:43,849 (New I/O server worker #1-1) [INFO -
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:141)]
[id: 0x7f328c7a, /127.0.0.1:57026 => /127.0.0.1:33334] CONNECTED: /
127.0.0.1:57026
2012-11-06 01:34:43,925 (New I/O server worker #1-1) [WARN -
org.apache.avro.ipc.Responder.respond(Responder.java:172)] system error
java.lang.ArrayIndexOutOfBoundsException: 36
        at
org.apache.avro.io.parsing.Symbol$Alternative.getSymbol(Symbol.java:364)
        at
org.apache.avro.io.ResolvingDecoder.doAction(ResolvingDecoder.java:229)
        at org.apache.avro.io.parsing.Parser.advance(Parser.java:88)
        at
org.apache.avro.io.ResolvingDecoder.readIndex(ResolvingDecoder.java:206)
        at
org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:148)
        at
org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:173)
        at
org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:144)
        at
org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:135)
        at org.apache.avro.ipc.Responder.handshake(Responder.java:208)
        at org.apache.avro.ipc.Responder.respond(Responder.java:117)
        at
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.messageReceived(NettyServer.java:158)
        at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)
        at
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:143)
        at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
        at
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:783)
        at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302)
        at
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:321)
        at
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:299)
        at
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:216)
        at
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)
        at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
        at
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
        at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274)
        at
org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261)
        at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:351)
        at
org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:282)
        at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:202)
        at
org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
        at
org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:619)
2012-11-06 01:34:43,940 (New I/O server worker #1-1) [INFO -
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:141)]
[id: 0x7f328c7a, /127.0.0.1:57026 :> /127.0.0.1:33334] DISCONNECTED
2012-11-06 01:34:43,940 (New I/O server worker #1-1) [INFO -
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:141)]
[id: 0x7f328c7a, /127.0.0.1:57026 :> /127.0.0.1:33334] UNBOUND
2012-11-06 01:34:43,940 (New I/O server worker #1-1) [INFO -
org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:141)]
[id: 0x7f328c7a, /127.0.0.1:57026 :> /127.0.0.1:33334] CLOSED
[WARN - org.apache.avro.ipc.Responder.respond(Responder.java:172)] system
errorNew I/O server worker #1-1) [WARN -
org.apache.avro.ipc.Responder.respond(Responder.java

AVRO Client

import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.apache.avro.Protocol;
import org.apache.avro.ipc.NettyTransceiver;
import org.apache.avro.ipc.specific.SpecificRequestor;

import com.cloudera.flume.handlers.avro.AvroFlumeEvent;
import com.cloudera.flume.handlers.avro.FlumeEventAvroServer;
import com.cloudera.flume.handlers.avro.Priority;

public class AvroRPCClient {
    public static void main(String[] args) throws IOException {
        //org.apache.avro.Protocol PROTOCOL = avro.test.Chat.PROTOCOL;
       /* URL url = new URL("http", "localhost", 22222, "/");
        HttpTransceiver transport = new HttpTransceiver(url);*/
        Protocol protocol = FlumeEventAvroServer.PROTOCOL;

        //System.out.println("Protocol :: "+protocol.toString());
        InetSocketAddress  isa =new
InetSocketAddress(InetAddress.getByName("localhost"), 33334);
        System.out.println("address=="+isa.getAddress());
        NettyTransceiver transport=new NettyTransceiver(isa);
        transport.setRemote(protocol);
        System.out.println("remote name ==== "+tran