hadoop - 使用 Log4j2 和 Flume 发送短信

Question

我有 Log4j2 配置:

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appenders>

        <Console name="console" target="SYSTEM_OUT">
            <PatternLayout pattern="%d %-5p - %m%n"/>
        </Console>
      <Flume name="flume" >
            <MarkerFilter marker="FLUME" onMatch="ACCEPT" onMismatch="DENY"/>
            <Agent host="IP_HERE" port="6999"/>
      </Flume>
      <File name="file" fileName="flume.log">
            <MarkerFilter marker="FLUME" onMatch="ACCEPT" onMismatch="DENY"/>
        </File>      
    </appenders>

    <loggers>
        <root level="info">
            <appender-ref ref="file"/>
            <appender-ref ref="console"/>
         <appender-ref ref="flume"/>
        </root>

    </loggers>
</configuration>

和 Flume 代理:

agent1.channels = ch1
agent1.sources = avro-source1
agent1.sinks = hdfs-sink1

agent1.channels.ch1.type = memory

agent1.sources.avro-source1.type = avro
agent1.sources.avro-source1.bind = IP_HERE
agent1.sources.avro-source1.port = 6999

agent1.sinks.hdfs-sink1.type = hdfs
agent1.sinks.hdfs-sink1.hdfs.path = hdfs://hadoop/user/hduser/bond/flume
agent1.sinks.hdfs-sink1.hdfs.fileType = DataStream
agent1.sinks.hdfs-sink1.hdfs.writeFormat = Text


agent1.sinks.hdfs-sink1.channel = ch1
agent1.sources.avro-source1.channels = ch1

当我发送日志时，第一次在我的 Web 服务器控制台上出现错误:“错误递归调用 appender flume”，(Flume 代理处于事件状态并且它已正确进行绑定(bind)过程)在下一个记录器事件上没有错误和文件是写在hadoop上的，但是当我尝试用HUE在文本模式下可视化它时，我无法看到我发送的文本，我只看到二进制代码......
有什么错误吗？或者我必须做什么才能以文本模式编写文件？
谢谢

Answer 1

一样容易:

代替:

 <Flume name="flume" >

是:

<Flume name="flume" compress="false" type="Avro">

多亏了 example