flink on native k8s

flink on native k8s 按照官网配置，可以看到jobmanager ui 但是没有tm为0 slot为0 提交任务 就会一直卡主

角色配置： [root@node20 rbac]# cat rbac-role.yaml kind: Role apiVersion: rbac.authorization.k8s.io/v1 metadata: namespace: di-flink-dev name: flink-admin rules: - apiGroups: [""] resources: ["pods"] verbs: ["create","delete","get", "watch", "list"]

角色绑定： [root@node20 rbac]# cat rbac-serviceaccount.yaml apiVersion: rbac.authorization.k8s.io/v1 kind: RoleBinding metadata: name: flink-admin-bind namespace: di-flink-dev subjects: - kind: Group name: system:serviceaccounts:di-flink-dev apiGroup: rbac.authorization.k8s.io roleRef: kind: Role name: flink-admin apiGroup: rbac.authorization.k8s.io

session启动命令： ./bin/kubernetes-session.sh -Dkubernetes.cluster-id=my-cluster-test01 -Dkubernetes.namespace=di-flink-dev -Dkubernetes.rest-service.exposed.type=NodePort -Dtaskmanager.memory.process.size=1028m -Dkubernetes.taskmanager.cpu=2 -Dtaskmanager.numberOfTaskSlots=2 -Dresourcemanager.taskmanager-timeout=3600000

任务提交命令： ./bin/flink run -d -t kubernetes-session -Dkubernetes.cluster-id=my-cluster-test01 -Dkubernetes.namespace=di-flink-dev examples/streaming/WindowJoin.jar

*来自志愿者整理的flink邮件归档