flink- Could not acquire the minimum required resources
发现并不能和 flink-jobmanager 进行通信。Available Task Slots都显示始终是0。属性,将其调大,结果还是没用。查看 k8s ,发现少了。重启 flink, 解决。
·
flink- Could not acquire the minimum required resources
问题 Could not acquire the minimum required resources
taskmanager.numberOfTaskSlots
首先修改 taskmanager.numberOfTaskSlots: 4
属性,将其调大,结果还是没用
Available Task Slots都显示始终是0
查看flink-taskmanager 日志
发现并不能和 flink-jobmanager 进行通信
flink-taskmanager与flink-jobmanager 是通过 jobmanager.rpc.address: flink-jobmanager
指定的地址通信的
查看 k8s ,发现少了 jobmanager-service.yaml
apiVersion: v1
kind: Service
metadata:
name: flink-jobmanager
spec:
type: ClusterIP
ports:
- name: rpc
port: 6123
- name: blob-server
port: 6124
- name: webui
port: 8081
selector:
app: flink
component: jobmanager
重启 flink, 解决
太坑了!!
附 flink k8s 安装 步骤
更多推荐
已为社区贡献5条内容
所有评论(0)