栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink作业的启动、暂停、停止与重启

Flink作业的启动、暂停、停止与重启

在flink-sql界面里启动一个flink任务

 

停止任务

停止作业时,系统会自动清除作业相关的Checkpoint信息。

1.使用命令行停止

先使用flink list找到所有运行的任务中你要停止的任务

使用命令flink cancel [job_id]来停止

显示Cancelled说明任务已经停止

2.在ui界面中停止

暂停任务

暂停作业时,系统会默认执行一次Savepoint后结束作业运行。

flink cancel -s  [job_id]

启动停止的作业

 

flink cancel 能接的参数的含义

cancel [target]

- s, withSavepoint   弃用警告:取消带有保存点的作业不赞成使用。使用"停止"。触发保存点并取消作业。
target目录是可选的。如果没有指定目录,配置默认目录( state.savepoints.dir)使用。
 ##state.savepoints.dir在flink-conf.yaml配置
通用CLI模式的选项:
- d 允许指定多个通用配置选项。可用的选项可以在https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html
- e,--executor 弃用:请使用-t选项代替也可与"应用模式"。将用于执行的执行者的名称给定的工作,这就相当于" 执行。target"配置选项。
当前可用的执行人:"remote", "local","kubernetes-session", "yarn-per-job", "yarn-session".
-t,--target 给定应用程序的部署target,这相当于"execution.target"配置选择。
 对于"运行"操作,当前可用target是:"remote", "local", "kubernetes-session","yarn-per-job", "yarn-session"。
 为"run-application"操作当前可用target是:"kubernetes-application"。
yarn-cluster集群模式的选择:
- m, --jobmanager 设置为YARN -cluster以使用YARN执行模式。
-yid,--yarnapplicationId 附加到正在运行的YARN会话
-z,--zookeeperNamespace 命名空间,创建Zookeeper高可用性模式的子路径
默认模式的选项:
-D 允许指定多个泛型配置选项。可用的可以在选项 https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html
-m,--jobmanager 要去的JobManager的地址连接。使用此标志连接到不同于指定的JobManager在配置。注意:这选项只有在高可用性配置为NONE。
-z,--zookeeperNamespace 命名空间,创建Zookeeper子路径对于高可用性模式

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/687355.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号