容器化部署时目前业界很流行的一项技术,基于Docker镜像运行能够让用户更加方便地对应用进行管理和运维。容器管理工具中最为流行的就是Kubernetes(k8s),而Flink也在最近的版本中支持了k8s部署模式。

  1. 搭建Kubernetes集群(略)

  2. 配置各组件的yaml文件

在k8s上构建Flink Session Cluster,需要将Flink集群的组件对应的docker镜像分别在k8s上启动,包括JobManager、TaskManager、JobManagerService三个镜像服务。每个镜像服务都可以从中央镜像仓库中获取。

  1. 启动Flink Session Cluster

    // 启动jobmanager-service 服务
    kubectl create -f jobmanager-service.yaml
    // 启动jobmanager-deployment服务
    kubectl create -f jobmanager-deployment.yaml
    // 启动taskmanager-deployment服务
    kubectl create -f taskmanager-deployment.yaml
  2. 访问Flink UI页面

    集群启动后,就可以通过JobManagerServicers中配置的WebUI端口,用浏览器输入以下url来访问Flink UI页面了:

    http://{JobManagerHost:Port}/api/v1/namespaces/default/services/flink-jobmanager:ui/proxy

Logo

K8S/Kubernetes社区为您提供最前沿的新闻资讯和知识内容

更多推荐