如果要使用官方的 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/

回复