天天看點

flume java.lang.no_Flume - 無法配置接收器 - 沒有為接收器配置通道

我已經配置了flume來讀取日志檔案并寫入HDFS . 當我啟動水槽時,會讀取日志檔案,但不會寫入HDFS . flume.log 有警告消息 - could not configure sink - no channel configured for sink 但我已經在conf檔案中配置設定了一個通道 .

下面給出了conf-file和錯誤消息:

File: spool-to-hdfs.properties

# List all components.

agent1.sources = source1

agent1.sinks = sink1

agent1.channels = channel1

# Describe source.

agent1.sources.source1.type = spooldir

agent1.sources.source1.spoolDir =/Suriya/flume/input_files

# Describe channel

#agent1.channels.channel1.type = file

#agent1.channels.channel1.checkpointDir = /Suriya/flume/checkpointDir

#agent1.channels.channel1.dataDirs =/Suriya/flume/dataDirs

agent1.channels.channel1.type = memory

# Describe sink

agent1.sinks.sink1.type = hdfs

#agent1.sinks.sink1.hdfs.path = hdfs://sandbox.hortonworks.com:8020/hdfs/Suriya/flume

agent1.sinks.sink1.hdfs.path = hdfs://localhost/hdfs/Suriya/flume

agent1.sinks.sink1.hdfs.fileType= DataStream

agent1.sinks.sink1.hdfs.writeFormat = Text

# Bind source and sink to channel

agent1.sources.source1.channels = channel1

agent1.sinks.sink1.channels = channel1

**-- starting the agent**

flume-ng agent --conf-file spool-to-hdfs.properties --conf /etc/flume/conf --name agent1;

flume.log

03 Aug 2015 23:37:16,699 WARN [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.validateSinks:697) - Could not configure sink sink1 due to: No channel configured for sink: sink1

org.apache.flume.conf.ConfigurationException: No channel configured for sink: sink1 at org.apache.flume.conf.sink.SinkConfiguration.configure(SinkConfiguration.java:51)