因为工作需要需要研究一下Flink,在此记录一下Flink的安装和启动
安装环境为CentOS,Flink版本为1.4.0,安装Flink之前确保已经安装Java1.8版本及以上
[root@node2 flink]# java -version openjdk version "1.8.0_161" OpenJDK Runtime Environment (build 1.8.0_161-b14) OpenJDK 64-Bit Server VM (build 25.161-b14, mixed mode)
将Flink放到服务器上,我这里放到了 /usr/flink目录下
解压缩包:
tar xzf flink-1.4.0-bin-hadoop27-scala_2.11.tgz
进入Flink目录:
cd flink-1.4.0
启动Flink:
[root@node2 flink-1.4.0]# ./bin/start-local.sh Warning: this file is deprecated and will be removed in 1.5. Starting cluster. Starting jobmanager daemon on host node2. Starting taskmanager daemon on host node2.
查看界面:
关闭Flink:
[root@node2 flink-1.4.0]# ./bin/stop-local.sh Warning: this file is deprecated and will be removed in 1.5. Stopping taskmanager daemon (pid: 10063) on host node2. Stopping jobmanager daemon (pid: 9757) on host node2.