linux 安装Flink_飞连linux

第一：前期准备环境：

1. JDK安装，本机安装使用jdk8
2. nc 网络通信安装
   yum 安装nc，已安装的同学可以跳过
   yum install -y nc

第二: 下载flink 安装包
官网地址：https://flink.apache.org/downloads.html

# 下载对应版本的安装包
wget https://archive.apache.org/dist/flink/flink-1.9.0/flink-1.9.0-bin-scala_2.11.tgz

#解压文件
tar -zxvf flink-1.9.0-bin-scala_2.11.tgz

#重新命名
mv flink-1.9.0-bin-scala_2.11.tgz flink-1.9.0

1
2
3
4
5
6
7
8
9

第三：配置环境变量

#添加环境变量
$ vim /etc/profile
export FLNK_HOME=/wwwroot/java/flink/flink-1.9.0
export PATH=$FLINK_HOME/bin:$PATH
#
1
2
3
4
5

第四：启动flink

#启动flink
/wwwroot/java/flink/flink-1.9.0/bin/start-cluster.sh
#查看是否启动
[root@VM_0_3_centos bin]# jps
13105 QuorumPeerMain
12069 StandaloneSessionClusterEntrypoint
13839 Jps

1
2
3
4
5
6
7
8

第五：启动成功后t通过web访问
JobManager同时会在8081端口上启动一个web前端，通过http://localhost:8081来访问
默认端口是8081 可以修改config 配置端口

可以通过web 提交job 任务，也可以通过命令行执行

第六命令执行job

#在一个窗口启动一个websocket 端口9099
nc -l -p 9099
#再开一个端口执行flink 例子
./flink run ../examples/streaming/WordCount.jar --port 9099
1
2
3
4

简单的wordCount 例子就完成了！

腾讯云搞活动！！