软件安装版本号说明:
JDK：1.8.0_302
Flink：flink-1.14.2-bin-scala_2.11
linux：CentOS 7.0
一、安装
1.官网下载(https://flink.apache.org/downloads.html) Apache Flink 1.14.2 for Scala 2.11版本
2.上传至服务器并解压文件
tar -xvf flink-1.14.2-bin-scala_2.11.tgz
3.启动Flink
cd $Flink_HOME ./bin/start-cluster.sh Starting cluster
进入flink下bin目录执行start-cluster.sh脚本启动Flink(暂不用修改配置)
二、初体验
1.在浏览器键入http://ip:8081 进入Flink Web UI
2.在Flink 1.14.2 二进制发布包中官方已经提供了部分demo供用户测试和体验，我们可以在flink目录下examples中找到。本次体验使用经典、简单的WordCount.jar
3.运行测试示例
cd $Flink_HOME /bin/flink run ./examples/streaming/WordCount.jar
4.检查Flink Web UI "Job -> Runing Jobs"中的作业
5.如果应用是流式的,它会一直运行下去,直到你手动取消。取消的方式是在UI中选定作业，然后点击Cancel按钮。
6.如果作业是批量的，在作业结束后作业状态更改为FINISHED，可以在Flink Web UI "Job -> Completed Jobs"中查看。
7.关闭Flink服务
cd $Flink_HOME ./bin/stop-cluster.sh
未完待续...
