Flink K8S提交

1.创建namespace kubectl create namespace flink-session-cluster-test   2.创建账号 kubectl create serviceaccount flink-test -n flink-session-cluster-test   3.创建角色并绑定到namespace kubectl create clusterrolebinding flink-role-binding-flink --clusterrole=edit --serviceaccount=flink-session-cluster-test:flink-test   4.以上述账号提交作业到相应的namespace flink 1.13 4.1首先创建flink cluste ./bin/kubernetes-session.sh -Dkubernetes.cluster-id=my-first-flink-cluster -Dkubernetes.namespace=flink-session-cluster-test -Dkubernetes.service-account=flink-test -Dkubernetes.rest-service.exposed.type=NodePort -Dkubernetes.container.image=flink:1.13.1-scala_2.11-java8 -Dkubernetes.container.image.pull-policy=Always 4.2提交作业到上面的cluster ./bin/flink run -d --target kubernetes-session -Dkubernetes.namespace=flink-session-cluster-test -Dkubernetes.cluster-id=my-first-flink-cluster -c SentenceSender ./examples/streaming/FlinkSample.jar   5.附录 5.1 服务暴露的方式指定为NodePort 不然无法连接 kubernetes.service.exposed.type=NodePort kubernetes.rest-service.exposed.type=NodePort 5.2 可以登陆到pod中去看相关的环境 kubectl exec -it --namespace flink-session-cluster-test pod/example-c675c658c-qqz8x -- bash