在采取保存点和停止管道之前，发送MAX_WATERMARK
-p
savepointPath 保存点的路径 'xxxxx'
-m
–jobmanager 指定连接的jobmanager
-yid
–yarnapplicationId 挂到指定的yarn id对应的yarn session上
-z
–zookeeperNamespace 用来创建ha的zk子路径的命名空间
cancel(弱化)
./bin/flink cancel [OPTIONS] OPTIONS | 功能说明 |
-s | 使用 "stop "代替 |
-D | 允许指定多个通用配置选项 |
-m | 要连接的JobManager的地址 |
-yid | –yarnapplicationId 挂到指定的yarn id对应的yarn session上 |
-z | –zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
savepoint
./bin/flink savepoint [OPTIONS] OPTIONS | 功能说明 |
-d | 要处理的保存点的路径 |
-j | Flink程序的JAR文件 |
-m | 要连接的JobManager的地址 |
-yid | –yarnapplicationId 挂到指定的yarn id对应的yarn session上 |
-z | –zookeeperNamespace 用来创建ha的zk子路径的命名空间 |
文章非原创，内容来源于微信公众号 「大数据左右手」
