前置条件

• 要求jdk1.8 或者jdk11

通过下面命令查看：
java -version

下载

执行：
tar -xzf flink-1.11.0-bin-scala_2.11.tgz
cd flink-1.11.0-bin-scala_2.11

启动集群

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

运行wordcount

$ ./bin/flink run examples/streaming/WordCount.jar
$ tail log/flink-*-taskexecutor-*.out
  (to,1)
  (be,1)
  (or,1)
  (not,1)
  (to,2)
  (be,2)

停止集群

$ ./bin/stop-cluster.sh