当前位置:网站首页>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
边栏推荐
- Large neural networks may be beginning to realize: the chief scientist of openai leads to controversy, and everyone quarrels
- 【虚幻】按键开门蓝图笔记
- [illusory] automatic door blueprint notes
- Zlib download and use
- [Fantasy 4] introduction and use of UMG components (under update...)
- Ue5 - ai Pursuit (Blueprint, Behavior tree)
- Blender多镜头(多机位)切换
- 【避坑指南】使用UGUI遇到的坑:Text组件无法首行缩进两格
- Excuse me, is it cost-effective to insure love life patron saint 2.0 increased lifelong life insurance? What are the advantages of this product?
- Flink实时计算topN热榜
猜你喜欢

flink 提交程序
![[Fantasy 4] the transformation from U3D to UE4](/img/bb/665eba3c8cd774c94fe14f169121da.png)
[Fantasy 4] the transformation from U3D to UE4

ICLR 2022: how does AI recognize "things I haven't seen"?

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

Blender海洋制作

UE4夜间打光笔记

Blender摄像机环绕运动、动画渲染、视频合成

【虚幻】过场动画笔记

2021-10-04

Configuration programmée du générateur de plantes du moteur illusoire UE - - Comment générer rapidement une grande forêt
随机推荐
Blender石头雕刻
[pit avoidance guide] pit encountered using ugui: the text component cannot indent the first line by two spaces
ue虚幻引擎程序化植物生成器设置——如何快速生成大片森林
Postman -- use
Message mechanism -- getting to know messages and message queues for the first time
01-spooldir
快速做出原型
【虚幻4】从U3D到UE4的转型之路
What is the relationship between realizing page watermarking and mutationobserver?
Flink实时计算topN热榜
2021-09-12
[200 Shengxin literatures] 95 multiomics exploration TNBC
Edge computing accelerates live video scenes: clearer, smoother, and more real-time
pytest框架实现前后置
Vscode auto format
2021-10-04
2021-10-02
Zlib download and use
[ue5] blueprint making simple mine tutorial
sqoop的表的导入