flink任务从Checkpoint中恢复时,如果yarn-session 也关闭了, 怎么恢复?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

flink任务从Checkpoint中恢复时,如果yarn-session 也关闭了, 怎么恢复?

冷丰 2019-01-02 18:13:33 3550

当yarn-session存在时,恢复成功.
当yarn-session不存在恢复时报错:
Caused by: java.lang.RuntimeException: The Yarn application application_1545734329511_0092 doesn't run anymore.
application application_1545734329511_0092 是yarn session的 yarn id.

我恢复的命令是:
flink run -s hdfs://nameservice1/flink/flink-checkpoints/9960a0c220fd1fa1f21979cb5435afb6/chk-20/_metadata --class ${MAIN_CLASS} ${LIB_DIR}/${LIB_NAME}
变量值替换是对的

资源调度 流计算
分享到
取消 提交回答
全部回答(2)
添加回答
大数据
使用钉钉扫一扫加入圈子
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题