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邮件归档
你的提交命令是没有问题的,需要确认一下Flink client和JM的rest endpoint的联通情况
可以curl一下flink run命令打出来的JM rest地址,看看网络通不通
*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。