1919 - 最终我选择了：Apache 1.7.0 Flink only Scala 2.11，共：240M
2020- 解压：` tar zxf flink-*.tgz `
2121- 进入根目录：` cd flink-1.7.0 ` ，完整路径：` cd /usr/local/flink-1.7.0 `
22- - 启动：` cd /usr/local/flink-1.7.0 && ./bin/start-cluster.sh `
23- - 停止：` cd /usr/local/flink-1.7.0 && ./bin/stop-cluster.sh `
22+ - 改下目录名方便后面书写：` mv /usr/local/flink-1.7.0 /usr/local/flink `
23+ - 启动：` cd /usr/local/flink && ./bin/start-cluster.sh `
24+ - 停止：` cd /usr/local/flink && ./bin/stop-cluster.sh `
2425- 查看日志：` tail -300f log/flink-*-standalonesession-*.log `
2526- 浏览器访问 WEB 管理：` http://192.168.0.105:8081 `
2627
2728## Demo
2829
29- - 运行程序解压包下也有一些 jar demo：` cd /usr/local/flink-1.7.0 /examples `
30+ - 运行程序解压包下也有一些 jar demo：` cd /usr/local/flink/examples `
3031- 官网：< https://ci.apache.org/projects/flink/flink-docs-release-1.7/examples/ >
3132- DataStream API：< https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/datastream_api.html >
3233- DataSet API：< https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/batch/ >
@@ -53,7 +54,7 @@ mvn archetype:generate \
5354
5455- 可以直接在 IntelliJ IDEA 上 run
5556- 也可以交给服务器上 flink 执行，也有两种方式：
56- - 把 jar 自己上传 Flink 服务器运行：`cd /usr/local/flink-1.7.0 && ./bin/flink run -c com.youmeek.WordCount /opt/flink-simple-demo-1.0-SNAPSHOT.jar`
57+ - 把 jar 自己上传 Flink 服务器运行：`cd /usr/local/flink && ./bin/flink run -c com.youmeek.WordCount /opt/flink-simple-demo-1.0-SNAPSHOT.jar`
5758 - 也可以通过 WEB UI 上传 jar：<http://192.168.0.105:8081/#/submit>
5859 - 有一个 `Add New` 按钮可以上传 jar 包，然后填写 Class 路径：`com.youmeek.WordCount`
5960 - `parallelism` 表示并行度，填写数字，一般并行度设置为集群 CPU 核数总和的 2-3 倍（如果是单机模式不需要设置并行度）
0 commit comments