日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

flume的配置和开启

發(fā)布時間:2023/12/3 编程问答 22 豆豆
生活随笔 收集整理的這篇文章主要介紹了 flume的配置和开启 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

配置文件:
編輯 flume-conf.properties

agent1表示代理名稱

agent1.sources=source1
agent1.sinks=sink1
agent1.channels=channel1

配置source1

agent1.sources.source1.type=spooldir
agent1.sources.source1.spoolDir=/usr/local/flume_logs
agent1.sources.source1.channels=channel1
agent1.sources.source1.fileHeader = false
agent1.sources.source1.interceptors = i1
agent1.sources.source1.interceptors.i1.type = timestamp

配置channel1

agent1.channels.channel1.type=file
agent1.channels.channel1.checkpointDir=/usr/local/flume_logs_tmp_cp
agent1.channels.channel1.dataDirs=/usr/local/flume_logs_tmp

配置sink1

agent1.sinks.sink1.type=hdfs
agent1.sinks.sink1.hdfs.path=hdfs://Spark1:9000/flume_logs
agent1.sinks.sink1.hdfs.fileType=DataStream
agent1.sinks.sink1.hdfs.writeFormat=TEXT
agent1.sinks.sink1.hdfs.rollInterval=1
agent1.sinks.sink1.channel=channel1
agent1.sinks.sink1.hdfs.filePrefix=%Y-%m-%d

開啟:切換到Flume的bin目錄下
./flume-ng agent -n agent1 -c conf -f /root/app/flume-1.5.0/conf/flume-conf.properties -Dflume.root.logger=DEBUG,consple

運行:
18/06/11 22:41:24 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:24 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:25 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:25 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:26 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:26 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:27 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:27 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:28 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:28 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:29 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:29 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.
18/06/11 22:41:30 INFO source.SpoolDirectorySource: Spooling Directory Source runner has shutdown.

完成!

總結

以上是生活随笔為你收集整理的flume的配置和开启的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。