You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by jiangjiguang719 <ji...@163.com> on 2020/11/25 12:26:57 UTC

flink on native k8s 没有

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

Re: flink on native k8s 没有

Posted by Yang Wang <da...@gmail.com>.

你的提交命令是没有问题的，需要确认一下Flink client和JM的rest endpoint的联通情况

可以curl一下flink run命令打出来的JM rest地址，看看网络通不通


Best,
Yang

jiangjiguang719 <ji...@163.com> 于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
>
>
>