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 | 4 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 | 4 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 | 4 years ago | Stern, Mark
    java.io.IOException: Error connecting to isk-vsrv710/10.231.148.171:41414

    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