文档:https://ifeve.com/flink-quick-start/
下载地址:https://flink.apache.org/downloads.html
下载: https://dlcdn.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz
解压:tar xzf flink-1.15.1-bin-scala_2.12.tgz
/opt/server/flink-1.15.1/conf
masters
修改内容:hdp1:8081
workers
修改内容:hdp1
flink-conf.yaml
修改内容:jobmanager.rpc.address:hdp1
classloader.resolve-order:parent-first
启动:./bin/start-cluster.sh
配置Nginx 代理
可通过代理访问:http://代理地址:端口/
记录:
Flink 的 Releases 附带了许多的示例作业。你可以任意选择一个,快速部署到已运行的集群上。
./bin/flink run examples/streaming/WordCount.jar
查看日志:
tail log/flink-*-taskexecutor-*.out