kubernetes - Connect ResourceManager for Flink FLIP-6 开始新的“会话作业”

Question

我想用会话作业创建一个新的 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.shFlink 进程之前创建一个内部负载均衡器。

标签： kubernetesapache-flinkflink-streaming

Answer 1

在 flink-conf.yaml 中，设置

high-availability.jobmanager.port: 6123

这将使资源管理器连接回到您希望它使用的静态端口。