小编Vin*_*wal的帖子

sink.hdfs writer在我的文本文件中添加了垃圾

我已成功配置flume以将文本文件从本地文件夹传输到hdfs.我的问题是当这个文件被转移到hdfs时,我的文本文件中会添加一些不需要的文本"hdfs.write.Longwriter + binary characters".这是我的flume.conf

agent.sources = flumedump
agent.channels = memoryChannel
agent.sinks = flumeHDFS

agent.sources.flumedump.type = spooldir
agent.sources.flumedump.spoolDir = /opt/test/flume/flumedump/
agent.sources.flumedump.channels = memoryChannel

# Each sink's type must be defined
agent.sinks.flumeHDFS.type = hdfs
agent.sinks.flumeHDFS.hdfs.path = hdfs://bigdata.ibm.com:9000/user/vin
agent.sinks.flumeHDFS.fileType = DataStream

#Format to be written
agent.sinks.flumeHDFS.hdfs.writeFormat = Text

agent.sinks.flumeHDFS.hdfs.maxOpenFiles = 10
# rollover file based on maximum size of 10 MB
agent.sinks.flumeHDFS.hdfs.rollSize = 10485760

# never rollover based on the number of events
agent.sinks.flumeHDFS.hdfs.rollCount = 0

# rollover file based on max time …
Run Code Online (Sandbox Code Playgroud)

hadoop flume flume-ng

2
推荐指数
1
解决办法
2157
查看次数

标签 统计

flume ×1

flume-ng ×1

hadoop ×1