一、Local本地模式
1、下载安装包
https://archive.apache.org/dist/flink/
使用的版本为 flink-1.13.2-bin-scala_2.11.tgz
2、准备文件
vi /xx/work/words.txt
3、启动Flink本机集群
cd /xx/work/flink-1.13.2/ bin/start-cluster.sh
查看jps
11972 StandaloneSessionClusterEntrypoint 12525 TaskManagerRunner
4、访问Flink的Web UI
http://192.168.xx.xx:8081/
5、执行word统计
cd /xx/work/flink-1.13.2/ ./flink run ../examples/batch/WordCount.jar --input /xx/work/words.txt --output /xx/work/wordOut.txt
查看wordOut.txt的结果
6、停止Flink
cd /xx/work/flink-1.13.2/ bin/stop-cluster.sh
7、启动shell交互窗口
$bin/start-scala-shell.sh local
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。