本地安装Flink_flink本地安装

一、下载安装包

注：运行Flink需要安装JAVA环境（Java 8 or 11）
可以查看环境是否已安装JAVA：
命令：　java -version　

下载Flink安装包
D ownload: https://flink.apache.org/downloads/ 

将下载的安装包进行解压：
$ tar -xzf flink-1.13.6-bin-scala_2.11.tgz
$ cd flink-1.13.6-bin-scala_2.11

二、启动本地集群

$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host.
Starting taskexecutor daemon on host.

三、提交Job作业 查看执行结果

$ ./bin/flink run examples/streaming/WordCount.jar
$ tail log/flink-*-taskexecutor-*.out
  (nymph,1)
  (in,3)
  (thy,1)
  (orisons,1)
  (be,4)
  (all,2)
  (my,1)
  (sins,1)
  (remember,1)
  (d,4)

四、关闭本地集群

$ ./bin/stop-cluster.sh