Flink环境搭建
安装Flink
Section titled “安装Flink”-
下载Flink
下载Flink并解压,Flink 官方下载地址
Terminal window tar xzf flink-*.tgz -
以本地模式启动
-
执行以下命令启动
Terminal window ./bin/start-cluster.sh -
打开网址http://localhost:8081/可以查看到flink web页面
-
-
使用flink官方示例
Terminal window nc -l 9000./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000 -
关闭集群
Terminal window ./bin/stop-cluster.shFlink 命令
Section titled “Flink 命令”bin/flink
Section titled “bin/flink”- run
- list
- stop
- cancel
- savepoint