启动
./start-cluster.sh
run
./bin/flink run [OPTIONS]
./bin/flink run -m yarn-cluster -c com.wang.flink.WordCount /opt/app/WordCount.jar
| OPTIONS |
功能说明 |
| -d |
detached 是否使用分离模式 |
| -m |
jobmanager 指定提交的jobmanager |
| -yat |
–yarnapplicationType 设置yarn应用的类型 |
| -yD |
使用给定属性的值 |
| -yd |
–yarndetached 使用yarn分离模式 |
| -yh |
–yarnhelp yarn session的帮助 |
| -yid |
–yarnapplicationId 挂到正在运行的yarnsession上 |
| -yj |
–yarnjar Flink jar文件的路径 |
| -yjm |
–yarnjobManagerMemory jobmanager的内存(单位M) |
| -ynl |
–yarnnodeLabel 指定 YARN 应用程序 YARN 节点标签 |
| -ynm |
–yarnname 自定义yarn应用名称 |
| -yq |
–yarnquery 显示yarn的可用资源 |
| -yqu |
–yarnqueue 指定yarn队列 |
| -ys |
–yarnslots 指定每个taskmanager的slots数 |
| -yt |
yarnship 在指定目录中传输文件 |
| -ytm |
–yarntaskManagerMemory 每个taskmanager的内存 |
| -yz |
–yarnzookeeperNamespace 用来创建ha的zk子路径的命名空间 |
| -z |
–zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
| -p |
并行度 |
| -yn |
需要分配的YARN容器个数(=任务管理器的数量) |
info
./bin/flink info [OPTIONS]
| OPTIONS |
功能说明 |
| -c |
程序进入点，主类 |
| -p |
并行度 |
list
./bin/flink list [OPTIONS]
| OPTIONS |
功能说明 |
| -a |
–all 显示所有应用和对应的job id |
| -r |
–running 显示正在运行的应用和job id |
| -s |
–scheduled 显示调度的应用和job id |
| -m |
–jobmanager 指定连接的jobmanager |
| -yid |
–yarnapplicationId 挂到指定的yarn id对应的yarn session上 |
| -z |
–zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
stop
./bin/flink stop [OPTIONS] <Job ID>
| OPTIONS |
功能说明 |
| -d |
在采取保存点和停止管道之前，发送MAX_WATERMARK |
| -p |
savepointPath 保存点的路径 'xxxxx' |
| -m |
–jobmanager 指定连接的jobmanager |
| -yid |
–yarnapplicationId 挂到指定的yarn id对应的yarn session上 |
| -z |
–zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
cancel(弱化)
./bin/flink cancel [OPTIONS] <Job ID>
| OPTIONS |
功能说明 |
| -s |
使用 "stop "代替 |
| -D |
允许指定多个通用配置选项 |
| -m |
要连接的JobManager的地址 |
| -yid |
–yarnapplicationId 挂到指定的yarn id对应的yarn session上 |
| -z |
–zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
savepoint
./bin/flink savepoint [OPTIONS] <Job ID>
| OPTIONS |
功能说明 |
| -d |
要处理的保存点的路径 |
| -j |
Flink程序的JAR文件 |
| -m |
要连接的JobManager的地址 |
| -yid |
–yarnapplicationId 挂到指定的yarn id对应的yarn session上 |
| -z |
–zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
