Linux运行环境搭建一个单机版Flink运行环境
- 下载Flink程序包：flink-1.8.1-bin-scala_2.11.tgz
- 部署在Linux服务器上，然后以单机模式运行
# cd flink
# tar xzf flink-1.8.1-bin-scala_2.11.tgz
# cd flink-1.8.1
# ./bin/start-cluster.sh
- 启动成功后，浏览器访问 ip:8081，即可访问Flink的web Dashboard
运行Flink自带的SocketwindowWordCount示例程序
- 启动新终端运行一个端口号为9000的Socker server
nc -l 9000
- 运行SocketwindowWordCount应用程序
./bin/flink run examples/streaming/SocketwindowWordCount.jar --port 9000
3.运行命令获取运行结果
tail -f log/flink-*-taskexecutor-*.out
输入示例
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
