Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Avro >> mail # user >> AVRO Flume Agent was genereted following Exception when i run my AVRO client (Exception and code follows)


Copy link to this message
-
AVRO Flume Agent was genereted following Exception when i run my AVRO client (Exception and code follows)
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
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB