我也遇到了,不知道啥原因,这个也是偶尔发生,是真的难定位问题


| |
田向阳
|
|
邮箱:lucas_...@163.com
|

签名由 网易邮箱大师 定制

在2021年04月28日 17:00,chaos 写道:
你好,因为业务逻辑变化,需要对线上在跑的flink任务重启,采用savapoint方式。

操作如下:
# 查看yarn-application-id
yarn application -list
# 查看flink任务id
flink list -t yarn-per-job
-Dyarn.application.id=application_1617064018715_0097
# 带有保存点的停止任务
flink stop -t yarn-per-job -p hdfs:///user/chaos/flink/0097_savepoint/
-Dyarn.application.id=application_1617064018715_0097
d7c1e0231f0e72cbd709baa9a0ba6415
Savepoint completed. Path:
hdfs://nameservice1/user/chaos/flink/0097_savepoint/savepoint-d7c1e0-96f5b07d18be
# 从保存点中重启任务
flink run -t yarn-per-job -s
hdfs://nameservice1/user/chaos/flink/0097_savepoint/savepoint-d7c1e0-96f5b07d18be
-d -c xxx xxx.jar

遇到的问题:
Service temporarily unavailable due to an ongoing leader election. Please
refresh

还请解惑,提前谢过!



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复