当前位置: 首页 > article >正文

如何在ubunt上安装flume

安装环境

虚拟机系统: Ubuntu
Hadoop 安装模式:伪分布式(单节点)
安装包: flume( 1.7.0
Apache Archive Distribution Directory

 

 安装步骤

(1)解压文件

tar -zvxf apache-flume-1.7.0-bin.tar.gz

(2)转移位置,移动到/usr/local/文件夹下

 sudo mv apache-flume-1.7.0-bin /usr/local/

(3)配置环境变量

vim安装命令:sudo apt install vim

sudo vim /etc/profile

 增加下面的代码,到最后

SQOOP_HOME=/usr/local/sqoop-1.4.7
PATH=$SQOOP_HOME/bin:$PATH
export SQOOP_HOME PATH

更新环境变量

source /etc/profile

 

 (4)测试安装

flume-ng version

 (5)配置文件

将flume-env.sh.template改名为flume-env.sh, 并修改其配置
在flume-1.7.0/conf目录下

cd /usr/local/flume-1.7.0/conf
sudo cp flume-env.sh.template flume-env.sh
sudo cp flume-conf.properties.template flume-conf.properties
sudo vim flume-1.7.0/conf/flume-env.sh 
export JAVA_HOME=/usr/local/jdk1.8

 

sudo vim flume-1.7.0-conf.properties

 增加下面内容,要根据自己的实际路径编辑

a1.sources = r1
a1.sinks = k1
a1.channels = c1
 
a1.sources.r1.type = exec
a1.sources.r1.command=tail -F /usr/local/hadoop-2.10.1/logs/hadoop-hadoop-namenode-master.log
 
a1.sinks.k1.type = hdfs
a1.sinks.k1.hdfs.path = hdfs://192.168.254.7:9000/tmp/flume/%Y%m%d
a1.sinks.k1.hdfs.filePrefix = log-
a1.sinks.k1.hdfs.fileType = DataStream
a1.sinks.k1.hdfs.useLocalTimeStamp = true
 
a1.channels.c1.type = memory
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1

将hadoop的hdfs-site.xml和core-site.xml 放到flume-1.7.0/conf下

sudo rm /usr/local/flume-1.7.0/lib/guava-11.0.2.jar

 测试启动

要根据自己的实际路径修改命令

flume-ng agent --conf conf/ --conf-file /usr/local/flume-1.7.0/conf/flume-conf.properties --name a1  -Dflume.root.logger=DEBUG,console

hdfs dfs -ls /tmp/flume


http://www.kler.cn/a/596156.html

相关文章:

  • 玩转python: Python并发编程-多线程的实战应用解析
  • Linux中安装redis
  • atop命令介绍(全面资源监控:同时监控CPU、内存、磁盘、网络和进程活动)性能监控、资源数据
  • Python---数据分析(Pandas六:二维数组DataFrame,DataFrame的创建,DataFrame的属性)
  • 如何在 HTML 中创建一个有序列表和无序列表,它们的语义有何不同?
  • ESP32-C6助力设备互联互通,Wi-Fi6无线通信方案,物联网交互联动
  • 卸载conda,poetry常用命令,vscode使用poetry虚拟环境
  • EmbodiedSAM:在线实时3D实例分割,利用视觉基础模型实现高效场景理解
  • AWS大数据解决方案实战解析:如何以低成本驱动企业数据智能升级
  • 电脑磁盘分盘
  • 大模型微调之早停(Early Stopping)
  • 避坑指南 | 阿里云服务器centos7上MySQL部署优化指南
  • 阶跃星辰开源300亿参数视频模型Step-Video-TI2V:运动可控+102帧长视频生成
  • 量化研究---可转债量化交易系统上线快速服务器
  • 003-掌控命令行-CLI11-C++开源库108杰
  • Spring Boot 中的 @ConditionalOnBean 注解详解
  • 第一次烧录51单片机的烧录不了的问题
  • 验证码设计与前端安全:实现方式、挑战与未来发展趋势深度分析
  • 架构师面试(十九):IM 架构
  • [leetcode]864. 获取所有钥匙的最短路径(状态压缩bitmask+bfs)