【Flink】Flink环境搭建
本篇文章以最简单的方式快速搭建Flink 1.12.0环境，供开发学习使用。
1. Flink安装
1.1 下载地址
Flink版本列表：
https://archive.apache.org/dist/flink/
最新版1.12.0下载地址：
https://archive.apache.org/dist/flink/flink-1.12.0/flink-1.12.0-bin-scala_2.12.tgz
1.2 安装Flink
下载1.12.0版本：
wget https://archive.apache.org/dist/flink/flink-1.12.0/flink-1.12.0-bin-scala_2.12.tgz
解压下载下来的压缩包：
tar -xzf flink-1.12.0-bin-scala_2.12.tgz
启动：
./bin/start-cluster.sh
检查是否启动成功:
[root@localhost flink-1.12.0]# jps -l | grep flink3922 org.apache.flink.runtime.taskexecutor.TaskManagerRunner3615 org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint
检查web ui是否启动成功：
http://ip:port:8081
2. Flink示例运行
2.1 批处理例子
使用flink自带的word count程序实现单词计数，如果不输入任何参数（输入文件路径和输出文件路径），则使用程序内置的数据：
[root@localhost flink-1.12.0]# ./bin/flink run ./examples/batch/WordCount.jar --output /home/happy/flink/output/wordcount-resultExecuting WordCount example with default input data set.Use --input to specify file input.Job has been submitted with JobID d1e96fab40dec4fffefa8b96674bd0eaProgram execution finishedJob with JobID d1e96fab40dec4fffefa8b96674bd0ea has finished.Job Runtime: 168 ms
查看结果：
more ../output/wordcount-resulta 5action 1after 1against 1all 2and 12arms 1arrows 1......
2.2 流处理例子
安装netcat：
yum install -y nc
监听tcp端口，发送数据：
nc -l 8881
启动流处理示例程序：
[root@localhost flink-1.12.0]# ./bin/flink run ./examples/streaming/SocketWindowWordCount.jar --port 8881Job has been submitted with JobID 41831fee1253dc7cd4a1e4dfee357916
发送数据：
aa bb bb cc
控制台输出结果：：
cc : 1aa : 1cc : 1bb : 2
2.3 Flink UI
内置的web-ui，默认端口为8081：
http://ip:port:8081
我们可以通过这也界面来提交和监控Flink程序，以及查看运行日志等等。
深藏阁楼爱情的钟
冷不防
灰太狼
ゞ 浴缸里的玫瑰
朱雀
我会带着你远行
忘是亡心i
还没有评论，来说两句吧...