2017-10-15 93 views
0

我得到以下错误消息,当我开始我的水槽剂:水槽错误:通道hdfschannel不活跃集

17/10/15 14:40:47 WARN conf.FlumeConfiguration: Could not configure sink hdfssink due to: Channel hdfschannel not in active set. 
org.apache.flume.conf.ConfigurationException: Channel hdfschannel not in active set. 

到HDFS下沉它不会写入任何文件。下面是我的水槽的配置文件:

fmp.sources = logsource 
    fmp.sinks = loggersink hdfssink 
    fmp.channels = loggerchannel hadfschannel 

    fmp.sources.logsource.type=exec 
    fmp.sources.logsource.command = tail -F /opt/gen_logs/logs/access.log 

    fmp.sinks.loggersink.type=logger 
    fmp.sinks.hdfssink.type=hdfs 
    fmp.sinks.hdfssink.hdfs.path=hdfs://quickstart.cloudera:8020/user/cloudera/flume 

    fmp.channels.loggerchannel.type=memory 
    fmp.channels.loggerchannel.capacity=1000 
    fmp.channels.loggerchannel.transactioncapacity=100 

    fmp.channels.hdfschannel.type=file 
    fmp.channels.hdfschannel.capacity=1000 
    fmp.channels.hdfschannel.transactioncapacity=100 

    fmp.sources.logsource.channels = hdfschannel loggerchannel 
    fmp.sinks.loggersink.channel = loggerchannel 
    fmp.sinks.hdfssink.channel = hdfschannel 
+0

这是什么?我不明白。抱歉。我是新的。 – Ravi

回答

0

您已经声明了一个名为渠道hadfschannel,并在你的其余配置你指的是一个名为hdfschannel通道。

+0

感谢您的更正。现在,我收到一条新的错误消息:17/10/16 19:33:17 ERROR node.AbstractConfigurationProvider:在配置过程中由于错误而删除了接收器hdfssink java.lang.IllegalStateException:接收器hdfssink未连接到通道在org.apache.flume.node.AbstractConfigurationProvider.loadSinks(AbstractConfigurationProvider.java:419) \t在org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:98)在org.apache.flume.node \t .PollingPropertiesFileConfigurationProvider $文件 – Ravi

+0

不幸的是,我们没有足够的信息。 您应该验证此线程(接受建议的更正)并针对此新错误以及更多详细信息(日志和新配置)提出新问题。 – Erms