设为首页 收藏本站
查看: 1154|回复: 0

[经验分享] Flume

[复制链接]

尚未签到

发表于 2015-11-27 17:13:37 | 显示全部楼层 |阅读模式
  Flume是一个分布式日志收集系统系统,具体的后面的文章会详细介绍。因为在使用Flame的过程中自定义了一些功能,所以需求重新打包,本篇只讲述如果编译,打包,导入eclipse阅读源码。
  编译过程中遇到些问题,网上找了好多资料,都无法解决。记录下来,希望能对需要的人有所帮助。
  1,通过git下载源码,最新版本是1.7.0,我编译的是1.7.0的快照版本
地址:https://github.com/apache/flume.git
DSC0000.jpg

2,mvn clean eclipse:clean

3,mvn install eclipse:eclipse -Dmaven.test.skip=true -Dtar
有以下报错,原因都是无法连接到maven.twttr.com,可能是被墙了。导致无法下载jar和pom文件
DSC0001.jpg


[ERROR] Failed to execute goal on project flume-ng-morphline-solr-sink: Could not resolve dependencies for project org.apache.flume.flume-ng-sinks:flume-ng-morphline-solr-sink:jar:1.7.0-SNAPSHOT: Failed to collect dependencies at
org.kitesdk:kite-morphlines-all:pom:1.0.0 -> org.kitesdk:kite-morphlines-useragent:jar:1.0.0 -> ua_parser:ua-parser:jar:1.3.0: Failed to read artifact descriptor for ua_parser:ua-parser:jar:1.3.0: Could not transfer artifact ua_pa
rser:ua-parser:pom:1.3.0 from/to maven-twttr (http://maven.twttr.com): Connect to maven.twttr.com:80 [maven.twttr.com/46.82.174.68] failed: Connection timed out: connect -> [Help 1]
  我没有试过翻墙能不能链接到maven.twttr.com。

解决办法是在根pom文件的标签添加下面的maven库地址。


<repository>
<id>maven.tempo-db.com</id>
<url>http://maven.oschina.net/service/local/repositories/sonatype-public-grid/content/</url>
</repository>
  maven.oschina.net是开源中国 “中国源” 项目的一个子系统,在不断进行完善当中,很靠谱国内maven库。有了它,妈妈再也不用担心你下不了依赖包了。嘿嘿!!!
  很多开源项目的jar和POM在http://search.maven.org无法找到,大家可以试试在http://maven.oschina.net
  OK,继续编译,又出现如下错误:

DSC0002.jpg

注释:flume-ng-channels\flume-kafka-channel\的


<!--
<dependency>
<groupId>org.apache.flume.flume-ng-sinks</groupId>
<artifactId>flume-ng-kafka-sink</artifactId>
<version>${project.version}</version>
<classifier>tests</classifier>
<scope>test</scope>
</dependency>
-->
  注释:\flume-ng-sinks\flume-ng-hbase-sink\


<!--            
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase</artifactId>
<classifier>tests</classifier>
<scope>test</scope>
</dependency>
-->
  Continue!

DSC0003.jpg

编译成功,导入到eclipse。尽情的阅读和修改源码吧。^-^
  最后需要注意flume的flume-hdfs-sink分两块:


<id>hadoop-1.0</id>

<id>hadoop-2</id>
  如果用的是hadoop2.X的,打包的时候需要指定,命令: mvn install eclipse:eclipse -Dmaven.test.skip=true -Phadoop-2 -Dtar
  生成:

apache-flume-1.7.0-SNAPSHOT-bin.tar.gz和apache-flume-1.7.0-SNAPSHOT-src.tar.gz
  关于flume后续将会持续更新。。。

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-144270-1-1.html 上篇帖子: 如何编写Flume-ng-morphline-avro-sink 下篇帖子: Flume几种监控方式
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表