分享web开发知识

注册/登录|最近发布|今日推荐

主页 IT知识网页技术软件开发前端开发代码编程运营维护技术分享教程案例
当前位置:首页 > 前端开发

WARN conf.FlumeConfiguration: Could not configure sink ?sink1 due to: No channel configured for sink: sink1 org.apache.flume.conf.ConfigurationException: No channel configured for sink: sink1

发布时间:2023-09-06 01:53责任编辑:傅花花关键词:apache

1、错误如下所示,启动flume采集文件到hdfs案例的时候,出现如下所示的错误:

大概是说No channel configured for sink,所以应该是sink哪里配置出现了错误,百度了一下,然后检查了一下自己的配置:

 1 18/04/24 08:31:02 WARN conf.FlumeConfiguration: Could not configure sink ?sink1 due to: No channel configured for sink: sink1 2 org.apache.flume.conf.ConfigurationException: No channel configured for sink: sink1 3 ????at org.apache.flume.conf.sink.SinkConfiguration.configure(SinkConfiguration.java:51) 4 ????at org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.validateSinks(FlumeConfiguration.java:681) 5 ????at org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.isValid(FlumeConfiguration.java:347) 6 ????at org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.access$000(FlumeConfiguration.java:213) 7 ????at org.apache.flume.conf.FlumeConfiguration.validateConfiguration(FlumeConfiguration.java:127) 8 ????at org.apache.flume.conf.FlumeConfiguration.<init>(FlumeConfiguration.java:109) 9 ????at org.apache.flume.node.PropertiesFileConfigurationProvider.getFlumeConfiguration(PropertiesFileConfigurationProvider.java:189)10 ????at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:89)11 ????at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:140)12 ????at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)13 ????at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)14 ????at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)15 ????at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)16 ????at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)17 ????at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)18 ????at java.lang.Thread.run(Thread.java:745)19 18/04/24 08:31:02 INFO conf.FlumeConfiguration: Post-validation flume configuration contains configuration for agents: [agent1]

2、解决方法如下所示:

参考链接如https://stackoverflow.com/questions/31798967/flume-could-not-configure-sink-no-channel-configured-for-sink

作者说应该是下面那种配置,一下子就明白了,自己的配置错误了,自己的如下所示:

修改以后,继续启动,解决问题。

 [hadoop@slaver1 soft]$ flume-ng agent -n agent1 -c conf -f flume-1.5.0-cdh5.3.6-bin/conf/flume-conf.properties -Dflume.root.logger=DEBUG,console

WARN conf.FlumeConfiguration: Could not configure sink ?sink1 due to: No channel configured for sink: sink1 org.apache.flume.conf.ConfigurationException: No channel configured for sink: sink1

原文地址:https://www.cnblogs.com/biehongli/p/8933559.html

知识推荐

我的编程学习网——分享web前端后端开发技术知识。 垃圾信息处理邮箱 tousu563@163.com 网站地图
icp备案号 闽ICP备2023006418号-8 不良信息举报平台 互联网安全管理备案 Copyright 2023 www.wodecom.cn All Rights Reserved