Flink入门简单命令

Flink入门简单命令 入门

1. 下载flink（需要有java8 or java11）并解压tar -xzf flink.tgz
2. 启动本地集群./bin/start-cluster.sh
3. 关闭集群./bin/stop-cluster.sh

提交Flink作业

换句话说就是把作业的jar文件和相关依赖上传到正在运行的Flink集群上并执行。(示例作业在examples文件夹中)

1. 把作业部署到正在运行的集群.bin/flink run jar包路径
2. 查看日志验证输出tail log/xxx.out

总结

本文主要是记录了集群的启动、停止以及提交作业并查看结果