如果要使用官方的 flink on k8s的 per-job模式: [1]
per-job模式下,每次启动新的job都需要通过taskmanager-job-deployment.yaml 和
jobmanager-job.yaml创建对应的 TM、JM。
终止任务,则需要删掉对应的yaml文件,也就是终止TM、JM:
kubectl delete -f taskmanager-job-deployment.yaml
kubectl delete -f jobmanager-job.yaml
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/kubernetes.html#deploy-job-cluster
--
Sent from: http://apache-flink.147419.n8.nabble.com/
- 关于 Flink on K8S Deploy Job Cluster 部署问题 WeiXubin
- Re: 关于 Flink on K8S Deploy Job Cluster 部署问题 caozhen
- Re:关于 Flink on K8S Deploy Job Cluster 部署问题 RS
