你的提交命令是没有问题的，需要确认一下Flink client和JM的rest endpoint的联通情况
可以curl一下flink run命令打出来的JM rest地址，看看网络通不通 Best, Yang jiangjiguang719 <[email protected]> 于2020年11月25日周三 下午8:28写道： > 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 > > >
