点击 Downloads (1.12.2 为Flink版本,2.11为scala版本)
下载 最新版 release 1.12.2 并解压。
tar -xzf flink-1.12.2-bin-scala_2.11.tgz
sudo mv flink-1.12.2 /opt cd /opt/flink-1.12.2
步骤 2:启动集群
vi /opt/flink-1.12.2/conf/flink-conf.yaml
#在尾部加入
jobmanager.archive.fs.dir: file:///home/jack/tmp/
historyserver.web.address: 0.0.0.0
historyserver.web.port: 8082
historyserver.archive.fs.dir: file:///home/jack/tmp/
historyserver.archive.fs.refresh-interval: 10000
Flink 附带了一个 bash 脚本,可以用于启动本地集群和历史服务器。
./bin/start-cluster.sh Starting cluster. Starting standalonesession daemon on host. Starting taskexecutor daemon on host.
./bin/historyserver.sh start
Starting historyserver daemon on host.
检查是否成功启动
jps
24593 HistoryServer #历史服务器
24246 TaskManagerRunner #任务执行器
23965 StandalonesessionClusterEntrypoint #独立集群
25102 Jps
注:历史服务器开启后可表里执行记录
步骤 3:提交作业(Job) Flink 的 Releases 附带了许多的示例作业。你可以任意选择一个,快速部署到已运行的集群上。 ./bin/flink run examples/streaming/WordCount.jar tail log/flink- * -taskexecutor- * .out (nymph,1) (in,3) (thy,1) (orisons,1) (be,4) (all,2) (my,1) (sins,1) (remember,1) (d,4) 另外,你可以通过 Flink 的 Web UI 来监视集群的状态和正在运行的作业。默认WebUI地址: http://localhost:8081/
默认的历史服务器地址:http://localhost:8082/
历史服务器与WebUI相同,但是没有提交任务的菜单
步骤 4:停止集群
完成后,你可以快速停止集群和所有正在运行的组件。
$ ./bin/stop-cluster.sh
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。