Bao's Blog

一个爱跑马的程序员


  • 首页

  • 关于

  • 标签

  • 归档

Savepoint 在 Flink On Yarn 下的使用

发表于 2019-01-15 | 更新于 2019-01-16 | 分类于 flink | 评论数:

配置文件

在 flink-conf.yaml 中配置 savepoint 的存储位置

1
state.savepoints.dir: hdfs:///flink/flink-checkpoints

列出当前job

1
2
3
flink list -yid [for yarn, applicationId] -z [zookeepernamesapce, for high availablity mode]

flink list -yid application_1541130324309_128080 -z cluster_by_job

停止job,并存储状态

1
2
3
flink cancel -s JobId -yid [for yarn, applicationId] -z [zookeepernamespace, for ha] 

flink cancel -s cababd2aadf69a263eda49df0f1efa82 -yid application_1541130324309_126267 -z cluster_by_job

从指定 savepoint 启动 job

1
flink run -s  hdfs:///flink/flink-checkpoints/savepoint-cababd-b92695040cfe  [args]

强力建议

Resume

发表于 2019-01-14 | 更新于 2019-01-18

联系方式

  • 手机:18616092141
  • Email: realleopard@126.com
阅读全文 »
豹子

豹子

2 日志
1 分类
2 标签
GitHub E-Mail
© 2019 豹子