当前位置:网站首页>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
边栏推荐
- Pycaret | a few lines of code to solve machine learning modeling
- 虚幻材质编辑器基础——如何连接一个最基本的材质
- 2021-10-02
- Vscode set JSON file to format automatically after saving
- ERROR 1118 (42000): Row size too large (> 8126)
- 【避坑指南】Unity3D项目接入腾讯Bugly工具时遇到的坑
- JS reduce accumulator
- Blender model import UE, collision settings
- 【Unity3D】制作进度条——让Image同时具有Filled和Sliced的功能
- 【教程】如何让VisualStudio的HelpViewer帮助文档独立运行
猜你喜欢

MongoDB-快速上手MongoDB命令行的一些简单操作

Post disaster reconstruction -- Floyd thought

Basic notes of illusory AI blueprint (10000 words)

Aiphacode is not a substitute for programmers, but a tool for developers

Message mechanism -- getting to know messages and message queues for the first time

flink 提交程序

It is the most difficult to teach AI to play iron fist frame by frame. Now arcade game lovers have something

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

Basic usage of mock server

Following nym, the new project Galaxy token announced by coinlist is gal
随机推荐
【Unity3D】嵌套使用Layout Group制作拥有动态子物体高度的Scroll View
2021-10-04
【Unity3D】无法正确获取RectTransform的属性值导致计算出错
[illusory] automatic door blueprint notes
sqoop创建job出现的一系列问题解决方法
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?
[pit avoidance guide] pit encountered by unity3d project when accessing Tencent bugly tool
ERROR 1118 (42000): Row size too large (> 8126)
传输优化抽象
【Unity3D】制作进度条——让Image同时具有Filled和Sliced的功能
判断数组中是否存在重复元素
AttributeError: type object ‘Image‘ has no attribute ‘fromarray‘
Project practice, redis cluster technology learning (VII)
Nonlinear optimization: steepest descent method, Newton method, Gauss Newton method, Levenberg Marquardt method
Following nym, the new project Galaxy token announced by coinlist is gal
UE5——AI追逐(藍圖、行為樹)
Project practice, redis cluster technology learning (13)
Remember a simple Oracle offline data migration to tidb process
Message mechanism -- getting to know messages and message queues for the first time
2021-10-02