Flink单机模式安装
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启动成功后,浏览器访问...
·
Linux运行环境搭建一个单机版Flink运行环境
Flink 下载地址: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
输入示例
更多推荐
已为社区贡献1条内容
所有评论(0)