flink on native k8s 没有

Wed, 25 Nov 2020 04:27:13 -0800 

flink版本：1.11
k8s版本：1.18  
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

回复