[LOG4J2-224] FlumeAppender creation fails if the Flume RPCClient cannot establish a connection.

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0-beta6
• Component/s: Flume Appender
• Assignee: Ralph Goers
• Reporter: Ralph Goers
• Created: 28/Apr/13 05:46
• Updated: 28/Apr/13 06:06
• Resolved: 28/Apr/13 06:06

Description

If no Flume agents are available the Flume Appender fails during creation with

2013-04-27 22:45:42,579 ERROR Could not create FlumeAvroManager org.apache.flume.FlumeException: NettyAvroRpcClient

{ host: localhost, port: 8800 }

: RPC connection error
at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:117)
at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:93)
at org.apache.flume.api.NettyAvroRpcClient.configure(NettyAvroRpcClient.java:507)
at org.apache.flume.api.RpcClientFactory.getInstance(RpcClientFactory.java:88)
at org.apache.logging.log4j.flume.appender.FlumeAvroManager.connect(FlumeAvroManager.java:206)
at org.apache.logging.log4j.flume.appender.FlumeAvroManager.<init>(FlumeAvroManager.java:68)
at org.apache.logging.log4j.flume.appender.FlumeAvroManager$AvroManagerFactory.createManager(FlumeAvroManager.java:263)
at org.apache.logging.log4j.flume.appender.FlumeAvroManager$AvroManagerFactory.createManager(FlumeAvroManager.java:252)
at org.apache.logging.log4j.core.appender.AbstractManager.getManager(AbstractManager.java:71)
at org.apache.logging.log4j.flume.appender.FlumeAvroManager.getManager(FlumeAvroManager.java:98)
at org.apache.logging.log4j.flume.appender.FlumeAppender.createAppender(FlumeAppender.java:219)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.logging.log4j.core.config.BaseConfiguration.createPluginObject(BaseConfiguration.java:764)
at org.apache.logging.log4j.core.config.BaseConfiguration.createConfiguration(BaseConfiguration.java:528)
at org.apache.logging.log4j.core.config.BaseConfiguration.createConfiguration(BaseConfiguration.java:520)
at org.apache.logging.log4j.core.config.BaseConfiguration.doConfigure(BaseConfiguration.java:169)
at org.apache.logging.log4j.core.config.BaseConfiguration.start(BaseConfiguration.java:123)
at org.apache.logging.log4j.core.LoggerContext.setConfiguration(LoggerContext.java:293)
at org.apache.logging.log4j.core.config.Configurator.initialize(Configurator.java:68)
at org.apache.logging.log4j.core.config.Configurator.initialize(Configurator.java:47)
at org.apache.logging.log4j.core.web.Log4jContextListener.contextInitialized(Log4jContextListener.java:61)
at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4887)
at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5381)
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:901)
at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:877)
at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:633)
at org.apache.catalina.startup.HostConfig.deployWAR(HostConfig.java:977)
at org.apache.catalina.startup.HostConfig$DeployWar.run(HostConfig.java:1655)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:680)
Caused by: java.io.IOException: Error connecting to localhost/127.0.0.1:8800
at org.apache.avro.ipc.NettyTransceiver.getChannel(NettyTransceiver.java:261)
at org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:203)
at org.apache.avro.ipc.NettyTransceiver.<init>(NettyTransceiver.java:152)
at org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:106)
... 37 more
Caused by: java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:396)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:358)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:274)
... 3 more