You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 研发-江志洋 <ej...@foxmail.com> on 2021/11/29 11:23:41 UTC

Flink1.13.3 on Native K8s 任务取消问题

你好,最近在使用Flink1.13.3 Application模式 on Native K8s部署任务,有几个问题不太理解:
1.在UI页面点击cancel取消任务,马上又会重新拉起来,达不到取消任务的目的?
2.通过kubectl delete deployment/cluster_id 命令删除任务后,通过bin/flink run-application方式起任务,会自动的从上次最后一个成功Checkpoint进行恢复,有什么方式可以不从ck恢复吗?


期复!

Re: Flink1.13.3 on Native K8s 任务取消问题

Posted by Yang Wang <da...@gmail.com>.
如果你使用的是native模式,设计上cancel job以后,所有K8s相关的资源会被释放,HA相关的信息也会自动被删除[1]

出现重新拉起是不符合预期的,你可以把JM日志发出来具体看一下

[1].
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/ha/kubernetes_ha/#high-availability-data-clean-up

Best,
Yang

研发-江志洋 <ej...@foxmail.com> 于2021年11月30日周二 上午9:39写道:

> 你好,最近在使用Flink1.13.3 Application模式 on Native K8s部署任务,有几个问题不太理解:
> 1.在UI页面点击cancel取消任务,马上又会重新拉起来,达不到取消任务的目的?
> 2.通过kubectl delete deployment/cluster_id 命令删除任务后,通过bin/flink
> run-application方式起任务,会自动的从上次最后一个成功Checkpoint进行恢复,有什么方式可以不从ck恢复吗?
>
>
> 期复!