专栏首页别先生WARN conf.FlumeConfiguration: Could not configure sink sink1 due to: No channel configured for sink

WARN conf.FlumeConfiguration: Could not configure sink sink1 due to: No channel configured for sink

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

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • java.lang.RuntimeException: Unable to instantiate org.apache.hadoop.hive.metastore.HiveMetaStoreClie

    别先生
  • 一脸懵逼学习hadoop之HDFS的java客户端编写

    1:eclipse创建一个项目,然后导入对应的jar包: 鼠标右击项目,点击properties或者alt+enter快捷键--->java build pat...

    别先生
  • springboot 使用 freemarker 无法正常跳转的问题?

    参考:https://blog.csdn.net/Lin_xiaofeng/article/details/79122053

    别先生
  • linux tomcat 无法关闭 :8005端口未启动

    版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_25283709/article/details/550...

    拓荒者
  • 搜索引擎排名技术,引爆网站流量,你也可以做到 第一课

    对于进行关键词排名,没有固定的模式,仅仅是基于传统经验之上慢慢摸索出来的一条道路,通过网站的一些设置让搜索引擎觉得网站更友好,提升搜索引擎蜘蛛停留时间,增加收录...

    做全栈攻城狮
  • Golang语言社区--wesocket的demo(包括H5前端,GO后端)

    go代码: package main import ( "flag" "fmt" "glog-master" ...

    李海彬
  • 避免顶级云访问风险的7个步骤

    在云中确保身份和数据的安全对于很多组织来说是一种挑战,但是最低权限的访问方法会有所帮助。

    静一
  • 进阶 | Java生成随机数的几种高级用法!

    Java技术栈
  • 语音合成论文与韩国小哥“撞车”后续:英伟达“赶紧”把代码开源了

    在得知自己的论文与英伟达的论文“撞车”之后,韩国小哥赶紧在arXiv上提交了论文。并在GitHub上放出了自己研究的源代码。

    量子位
  • 手机误删照片怎么恢复?最好的方法教你恢复

      手机误删照片怎么恢复?我们手机上都会有很多的照片在手机里面,不过有时候会觉得里面的照片太多就想清理掉一些用不到的照片,不过少部分照片会掺杂在重要的照片中,但...

    科技第六人

扫码关注云+社区

领取腾讯云代金券