当前位置:网站首页>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
边栏推荐
- Feature (5): how to organize information
- Tee command usage example
- 01-spooldir
- 2021-10-04
- Database -- acid of transaction -- introduction / explanation
- Pytest learning --base
- Project practice, redis cluster technology learning (12)
- 【Unity3D】制作进度条——让Image同时具有Filled和Sliced的功能
- Deep understanding of redis cache avalanche / cache breakdown / cache penetration
- [leetcode] sword finger offer 53 - I. find the number I in the sorted array
猜你喜欢

Large neural networks may be beginning to realize: the chief scientist of openai leads to controversy, and everyone quarrels

【避坑指南】使用UGUI遇到的坑:Text组件无法首行缩进两格
![[unreal] animation notes of the scene](/img/97/dafde0377b7c4337e1775db64ba6a4.png)
[unreal] animation notes of the scene

Tee command usage example
![[unity3d] nested use layout group to make scroll view with dynamic sub object height](/img/b2/edab4ab48e1401934dcce7218df662.png)
[unity3d] nested use layout group to make scroll view with dynamic sub object height

This article takes you to learn in detail what is fiber to home FTTH

Blender ocean production

2021-10-02

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

Flink实时计算topN热榜
随机推荐
[Fantasy 4] the transformation from U3D to UE4
虚幻AI蓝图基础笔记(万字整理)
Understand the composition of building energy-saving system
Mock Server基本使用方法
Bookmark collection management software suspension reading and data migration between knowledge base and browser bookmarks
flink 提交程序
[leetcode] sword finger offer 53 - I. find the number I in the sorted array
MySQL -- time zone / connector / driver type
SAP Spartacus express checkout design
Introduction and Principle notes of UE4 material
How to judge the quality of primary market projects when the market is depressed?
Pytest-- test report allure configuration
2021-09-12
[unity3d] cannot correctly obtain the attribute value of recttransform, resulting in calculation error
[unreal] key to open the door blueprint notes
【Unity3D】制作进度条——让Image同时具有Filled和Sliced的功能
ue4材质的入门和原理笔记
Project practice, redis cluster technology learning (11)
sqoop的表的导入
[MySQL] an exception occurs when connecting to MySQL: connection must be valid and open