美文网首页
flink系列--本地安装

flink系列--本地安装

作者: 老牛leixw | 来源:发表于2020-08-21 17:12 被阅读0次

前置条件

  • 要求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

相关文章

网友评论

      本文标题:flink系列--本地安装

      本文链接:https://www.haomeiwen.com/subject/sazujktx.html