kubernetes - 连接ResourceManager for Flink FLIP-6开始新的 “session job”

Question

我想用 session 作业创建一个新的k8s部署；并在taskmanager中使用这样的配置部署了一个flink-conf.yaml:

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 Job / standalone-job.sh Flink流程之前创建一个内部负载平衡器。

Answer 1

在flink-conf.yaml中，设置

high-availability.jobmanager.port: 6123

这将使资源管理器连接恢复到您要使用的静态端口。