版权声明: https://blog.csdn.net/xichengqc/article/details/91376187
- 下载(注:flink需要jdk版本在8.x之上):
https://flink.apache.org/downloads.html
下载Apache Flink 1.x.x for Scala 2.11 (asc, sha512),本地解压 - 运行
进入解压目录的bin目录,运行start-cluster.bat,启动成功后本地访问http://localhost:8081 - 执行一个程序
D:\software\flink-1.8.0-bin-scala_2.11\flink-1.8.0\bin>flink.bat run ../examples/batch/WordCount.jar
在页面的Running Jobs下面可以看到有一个任务在运行,这个任务执行的比较快,有可能看不到;
但是在Completed Jobs下面可以看到有一个已完成任务
如果想要这个任务执行的慢一点,可以修改input选项,自己做一个大一点的文件来运行
D:\software\flink-1.8.0-bin-scala_2.11\flink-1.8.0\bin>flink.bat run ../examples/batch/WordCount.jar -input ../examples/
batch/test.txt
此时可以看到Running Jobs下有任务运行