admin 管理员组

文章数量: 887016

Apache Flink: savepoint Operations

Flink版本：1.11.1
以下操作基于hadoop yarn

文章目录

    • 查看Job信息
    • 保存一个savepoint
    • cancel生成savepoint
    • 带savepoint重启job

查看Job信息

flink list yarn-cluster -yid application_1629715128130_0031

保存一个savepoint

flink savepoint 6eb006988b9ab8ca1feb180c04091d98 hdfs://hadoop102.dev:8020/flink-savepoints -yid application_1629715128130_0031

cancel生成savepoint

flink cancel -s hdfs://hadoop102.dev:8020/flink-savepoints 6eb006988b9ab8ca1feb180c04091d98 yarn-cluster -yid application_1629715128130_0031

带savepoint重启job

/data/software/flink-1.11.1/bin/flink run -m yarn-cluster -ynm DwsProductShopMemberDetail -yjm 1024 -ytm 1024 -s hdfs://hadoop102.dev:8020/flink-savepoints/savepoint-6eb006-26d797d303ff /data/shell/datawarehouse/jar/DwsProductShopMemberDetail.jar

验证：

停任务后先生成了一条订单，在重启任务后订单正常补回

本文标签： Apache Flink savepoint Operations

版权声明：本文标题：Apache Flink: savepoint Operations 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.freenas.com.cn/jishu/1732353784h1533852.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。