因为工作需要需要研究一下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.
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。