org.apache.flume.FlumeException: NettyAvroRpcClient { host: <ip>, port: 3564 }: RPC connection error

Stack Overflow | NorthPole | 3 years ago
  1. 0

    Component has no type when attempting to configure avro forward sink Apache flume

    Stack Overflow | 3 years ago | NorthPole
    org.apache.flume.FlumeException: NettyAvroRpcClient { host: <ip>, port: 3564 }: RPC connection error
  2. 0

    How to start Flume agent from java code

    Stack Overflow | 2 years ago | Uttam Raj
    org.apache.flume.FlumeException: NettyAvroRpcClient { host: collector1.apache.org, port: 5564 }: RPC connection error
  3. 0

    Problems with failover configuration

    incubator-flume-user | 5 years ago | Stern, Mark
    java.io.IOException: Error connecting to isk-vsrv710/10.231.148.171:41414
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Problems with failover configuration

    incubator-flume-user | 5 years ago | Stern, Mark
    java.io.IOException: Error connecting to isk-vsrv710/10.231.148.171:41414
  6. 0

    Problems with failover configuration

    incubator-flume-user | 5 years ago | Stern, Mark
    java.io.IOException: Error connecting to isk-vsrv710/10.231.148.171:41414

  1. chenjunjun 72 times, last 5 days ago
1 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.io.IOException

    Error connecting to /<ip>:3564

    at org.apache.avro.ipc.NettyTransceiver.getChannel()
  2. Apache Avro IPC
    NettyTransceiver.<init>
    1. org.apache.avro.ipc.NettyTransceiver.getChannel(NettyTransceiver.java:261)
    2. org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:203)
    3. org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:152)
    3 frames
  3. Flume NG SDK
    RpcClientFactory.getInstance
    1. org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:147)
    2. org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:115)
    3. org.apache.flume.api.NettyAvroRpcClient.configure(NettyAvroRpcClient.java:590)
    4. org.apache.flume.api.RpcClientFactory.getInstance(RpcClientFactory.java:88)
    4 frames
  4. Flume
    LifecycleSupervisor$MonitorRunnable.run
    1. org.apache.flume.sink.AvroSink.initializeRpcClient(AvroSink.java:127)
    2. org.apache.flume.sink.AbstractRpcSink.createConnection(AbstractRpcSink.java:209)
    3. org.apache.flume.sink.AbstractRpcSink.start(AbstractRpcSink.java:289)
    4. org.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:46)
    5. org.apache.flume.SinkRunner.start(SinkRunner.java:79)
    6. org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)
    6 frames
  5. Java RT
    Thread.run
    1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    2. java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
    3. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
    4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    5. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    6. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    7. java.lang.Thread.run(Thread.java:744)
    7 frames