【docker专题_03】docker搭建Flink集群

1.拉取镜像

代码语言：javascript复制

#默认拉取最新版本
docker pull flink

#检查镜像
docker images | grep flink

2.编写flink的yaml文件

注意：云服务器需要设置安全策略放行8081端口，否则访问失败

代码语言：javascript复制

编写yaml配置文件 docker-compose.yaml
version: "1.0"
services:
  jobmanager:
    image: flink
    expose:
      - "6123"
    ports:
      - "8081:8081"
    command: jobmanager
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager
 
  taskmanager:
    image: flink
    expose:
      - "6121"
      - "6122"
    depends_on:
      - jobmanager
    command: taskmanager
    links:
      - "jobmanager:jobmanager"
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager
      
#注释：
The Web Client is on port 8081
JobManager RPC port 6123
TaskManagers RPC port 6122
TaskManagers Data port 6121

3.执行docker-compose.yml文件

注意：docker-compose.yml文件同级目录执行

代码语言：javascript复制

#运行flink服务 
docker-compose up -d

#检查flink的docker容器是否启动
docker ps | grep flink

#查看进程是否存在
netstat -anltp|grep 8081

#检查日志是否正常
docker logs -f -t --tail 100 flink_taskmanager

4.登陆flink页面

注意：云服务器需要设置安全策略放行8081端口，否则访问失败

代码语言：javascript复制

http://124.71.65.6:8081

云服务器 容器 flink 集群 镜像

0 人点赞