连接-6\f25 Flink FLIP-6 \f6的-6\f25 ResourceManager -6\f6启动新的-6\f25“会话作业”-6\f6
连接-6\f25 Flink FLIP-6 \f6的-6\f25 ResourceManager -6\f6启动新的-6\f25“会话作业”-6\f6
提问于 2019-04-26 01:55:48
我希望使用会话作业创建一个新的k8s部署；并在flink-conf.yaml中使用如下配置部署一个taskmanager
jobmanager.rpc.address: analytics-job
jobmanager.rpc.port: 6123但是，似乎我的TaskManager拒绝使用端口6123，并且总是选择高端口？分析作业的k8s服务如下所示：
apiVersion: v1
kind: Service
metadata:
name: analytics-job
spec:
type: ClusterIP
ports:
- name: rpc
port: 6123
- name: blob
port: 6124
- name: query
port: 6125
# nodePort: 30025
- name: ui
port: 8081
# nodePort: 30081
selector:
app: analytics
stack: flink
component: job-cluster正如您所看到的，我已经尝试了ClusterIP和NodePort服务类型。我宁愿有一个ClusterIP类型，因为它会在我的k8s作业/standalone-job.sh闪烁进程前面创建一个内部负载均衡器。
回答 2
Stack Overflow用户
回答已采纳
发布于 2019-04-29 18:20:46
在flink-conf.yaml中，设置
high-availability.jobmanager.port: 6123这将使资源管理器连接返回到您希望它使用的静态端口。
Stack Overflow用户
发布于 2019-04-26 05:17:22
您无法获得Kubernetes master分配的nodePorts (如6123、6124和6125 )的原因是，有一个用于nodePorts的端口范围，该范围由kube-apiserver上的--service-node-port-range选项标识。该范围的默认值为30000-32767。
您只需将标志--service-node-port-range添加到您的kubeapi-server配置中，通常是在/etc/kubernetes/manifests/kube-apiserver.yaml下，值如下：
--service-node-port-range=6000-32767请记住，端口可能与您在节点上运行的其他一些服务重叠。
作为一个辅助节点，FLIP-6在K8s中是一个正在进行的工作(在撰写本文时)，您可以看到它在Kubernetes中非常简单，因为作业管理器并不是真正动态地创建您的任务管理器和分配资源。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/55855111
复制相关文章
相似问题
腾讯云开发者
