logging-log4j-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matt Sicker <boa...@gmail.com>
Subject Re: Errors with FlumeAppender
Date Tue, 09 Feb 2016 01:18:12 GMT
Are flume's logging events being logged to flume? That should cause the
recursion error.

On 8 February 2016 at 19:00, Tara Czutno <javaworkinggirl@gmail.com> wrote:

> I am trying out Flume, but I am getting an error:
> 2016-02-08 17:52:46,368 main DEBUG Shutdown hook enabled. Registering a new
> one.
> 2016-02-08 17:52:46,370 main DEBUG LoggerContext[name=504bae78,
> org.apache.logging.log4j.core.LoggerContext@5824a83d] started OK.
> 2016-02-08 17:52:46,388 main ERROR Recursive call to appender flume
> 2016-02-08 17:52:46,394 main ERROR Recursive call to appender flume
> 2016-02-08 17:52:46,464 main ERROR Recursive call to appender flume
> 2016-02-08 17:52:46,464 main ERROR Recursive call to appender flume
>
> Flume output:
>
> 2016-02-08 17:46:51,334 (conf-file-poller-0) [DEBUG -
>
> org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.isValid(FlumeConfiguration.java:372)]
> Post validation configuration for agent
>
> AgentConfiguration created without Configuration stubs for which only basic
> syntactical validation was performed[agent]
>
> SOURCES: {avroSrc={ parameters:{bind=localhost, channels=memoryChannel,
> port=8800, type=avro} }}
>
> CHANNELS: {memoryChannel={ parameters:{type=memory, capacity=100} }}
>
> AgentConfiguration created with Configuration stubs for which full
> validation was performed[agent]
>
> SINKS: {loggerSink=ComponentConfiguration[loggerSink]
>
>   CONFIG:
>
>     CHANNEL:memoryChannel
>
> }
>
> 2016-02-08 17:52:46,513 (New I/O  worker #3) [INFO -
>
> org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:171)]
> [id: 0xe2275c51, /127.0.0.1:61033 => /127.0.0.1:8800] BOUND: /
> 127.0.0.1:8800
>
> 2016-02-08 17:52:46,513 (New I/O  worker #3) [INFO -
>
> org.apache.avro.ipc.NettyServer$NettyServerAvroHandler.handleUpstream(NettyServer.java:171)]
> [id: 0xe2275c51, /127.0.0.1:61033 => /127.0.0.1:8800] CONNECTED: /
> 127.0.0.1:61033
> log4j2.xml:
>
> <Flume name="flume" ignoreExceptions="false" mdcPrefix="ReqCtx_"
> compress="false">
>    <Agent host="localhost" port="8800" />
>    <RFC5424Layout enterpriseNumber="12293" includeMDC="true"
> mdcId="RequestContext" appName="GL" />
> </Flume>
>
> <Root level="debug">
>     <AppenderRef ref="flume"/>
> </Root>
>
>
> Flume config:
>
> agent.sources = avroSrc
>
> agent.channels = memoryChannel
>
> agent.sinks =  loggerSink
>
> # For each one of the sources, the type is defined
>
> # agent.sources.seqGenSrc.type = seq
>
> agent.sources.avroSrc.type = avro
>
> agent.sources.avroSrc.bind = localhost
>
> agent.sources.avroSrc.port = 8800
>
> # The channel can be defined as follows.
>
> agent.sources.avroSrc.channels = memoryChannel
>
>
> # Each sink's type must be defined
>
> agent.sinks.loggerSink.type = logger
>
> #Specify the channel the sink should use
>
> agent.sinks.loggerSink.channel = memoryChannel
>
> # Each channel's type is defined.
>
> agent.channels.memoryChannel.type = memory
>
> # Other config values specific to each type of channel(sink or source)
>
> # can be defined as well
>
> # In this case, it specifies the capacity of the memory channel
>
> agent.channels.memoryChannel.capacity = 100
>



-- 
Matt Sicker <boards@gmail.com>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message