当前位置:网站首页>01-spooldir
01-spooldir
2022-07-02 10:31:00 【Lucky lucky】
-------------------------------------- spooldir -----------------------------------------
1、 establish cnf
vim flume_spooldir_file_hdfs.cnf
2、 Configuration information
# Component description
a1.sources = s1
a1.channels = c1
a1.sinks = k1
# Initialize the data source
a1.sources.s1.type = spooldir
a1.sources.s1.spoolDir = /root/data/flume
a1.sources.s1.ignorePattern = ^(.)*\\.bak$
a1.sources.s1.fileSuffix = .bak
# Initialize channel
a1.channels.c1.type = file
a1.channels.c1.checkpointDir = /opt/software/flume190/mydata/checkpoint
a1.channels.c1.dataDirs = /opt/software/flume190/mydata/data
a1.channels.c1.capacity = 100000
a1.channels.c1.transactionCapacity = 10000
# Initialize data slot
a1.sinks.k1.type = hdfs
a1.sinks.k1.hdfs.path = hdfs://192.168.19.130:9820/flume/events/fakeorder/%Y-%m-%d/%H
a1.sinks.k1.hdfs.round = true # Time abandonment
a1.sinks.k1.hdfs.roundValue = 10
a1.sinks.k1.hdfs.roundUnit = minute
a1.sinks.k1.hdfs.filePrefix = log_%Y%m%d_%H
a1.sinks.k1.hdfs.fileSuffix = .log
a1.sinks.k1.hdfs.useLocalTimeStamp = true
a1.sinks.k1.hdfs.writeFormat = Text
a1.sinks.k1.hdfs.rollCount = 0
a1.sinks.k1.hdfs.rollSize = 134217728
a1.sinks.k1.hdfs.bacthSize = 1000
a1.sinks.k1.hdfs.threadsPoolSize = 4
a1.sinks.k1.hdfs.idleTimeout = 0
a1.sinks.k1.hdfs.minBlockReplicas = 1
# Associated components
a1.sources.s1.channels = c1
a1.sinks.k1.channel = c1
3、 start-up
flume-ng agent -n a1 -c conf/ -f flume-conf-files/flume_spooldir_file_hdfs.cnf -Dflume.root.logger=INFO,console
边栏推荐
- The primary market project galaxy will conduct public offering on coinlist on February 17
- [200 Shengxin literatures] 96 joint biomarkers of immune checkpoint inhibitor response in advanced solid tumors
- [Fantasy 4] the transformation from U3D to UE4
- [jetbrain rider] an exception occurred in the construction project: the imported project "d:\visualstudio2017\ide\msbuild\15.0\bin\roslyn\microsoft.csh" was not found
- Network real-time video streaming based on OpenCV
- Blender stone carving
- Basic usage of mock server
- 判断数组中是否存在重复元素
- Vscode set JSON file to format automatically after saving
- [ue5] two implementation methods of AI random roaming blueprint (role blueprint and behavior tree)
猜你喜欢

Bookmark collection management software suspension reading and data migration between knowledge base and browser bookmarks

sqoop创建job出现的一系列问题解决方法

MongoDB-快速上手MongoDB命令行的一些简单操作
![[Fantasy 4] the transformation from U3D to UE4](/img/bb/665eba3c8cd774c94fe14f169121da.png)
[Fantasy 4] the transformation from U3D to UE4

What wires are suitable for wiring on bread board?
![[unreal] key to open the door blueprint notes](/img/28/f2b00d84dc05183ce93e2a8ee3555f.png)
[unreal] key to open the door blueprint notes

判断数组中是否存在重复元素

Delivery mode design of Spartacus UI of SAP e-commerce cloud

Leetcode -- the nearest common ancestor of 236 binary tree

Postman -- use
随机推荐
pytest框架实现前后置
The primary market project galaxy will conduct public offering on coinlist on February 17
Applet development summary
Deep understanding of redis cache avalanche / cache breakdown / cache penetration
Basic notes of illusory AI blueprint (10000 words)
快速做出原型
01安装虚拟机
Commutateur Multi - lentilles Blender
[MySQL] an exception occurs when connecting to MySQL: connection must be valid and open
Introduction and Principle notes of UE4 material
Vscode set JSON file to format automatically after saving
How much is it to develop a system software in Beijing, and what funds are needed to develop the software
Test -- Summary of interview questions
What is the relationship between realizing page watermarking and mutationobserver?
allure--常用配置项
Remember the use of add method once
Sum the two numbers to find the target value
[unity3d] production progress bar - make image have the functions of filled and sliced at the same time
Project practice, redis cluster technology learning (10)
Large neural networks may be beginning to realize: the chief scientist of openai leads to controversy, and everyone quarrels