flink系列--本地安装
作者:
老牛leixw | 来源:发表于
2020-08-21 17:12 被阅读0次
前置条件
通过下面命令查看:
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
网友评论