• Windows下Docker搭建Flink集群


    编写docker-compose.yml

    参照:https://github.com/docker-flink/examples/blob/master/docker-compose.yml

    1. version: "2.1"
    2. services:
    3. jobmanager:
    4. image: flink:1.14.4-scala_2.11
    5. expose:
    6. - "6123"
    7. ports:
    8. - "18081:8081"
    9. command: jobmanager
    10. environment:
    11. - JOB_MANAGER_RPC_ADDRESS=jobmanager
    12. taskmanager:
    13. image: flink:1.14.4-scala_2.11
    14. expose:
    15. - "6121"
    16. - "6122"
    17. depends_on:
    18. - jobmanager
    19. command: taskmanager
    20. links:
    21. - "jobmanager:jobmanager"
    22. environment:
    23. - JOB_MANAGER_RPC_ADDRESS=jobmanager
    24. scale: 2 #指定TaskManager的数量

    在docker-compose.yml所有目录执行以下命令:

    docker-compose up -d

    执行过程:

    [+] Running 14/14
     ✔ taskmanager 12 layers [⣿⣿⣿⣿⣿⣿⣿⣿⣿⣿⣿⣿]      0B/0B      Pulled                                                   129.9s
       ✔ e756f3fdd6a3 Pull complete                                                                                   17.7s
       ✔ bf168a674899 Pull complete                                                                                    8.6s
       ✔ e604223835cc Pull complete                                                                                   19.0s
       ✔ b879d05afe7d Pull complete                                                                                   17.7s
       ✔ a54258f91250 Pull complete                                                                                   20.7s
       ✔ c395a90ab0cf Pull complete                                                                                   30.3s
       ✔ b79b6485357a Pull complete                                                                                   22.8s
       ✔ 7a587b6ad6b3 Pull complete                                                                                   28.5s
       ✔ 9021ca31d420 Pull complete                                                                                   26.8s
       ✔ b215a7eba672 Pull complete                                                                                   32.2s
       ✔ de1d611fa80f Pull complete                                                                                  107.8s
       ✔ 9354c4dc24c1 Pull complete                                                                                   35.4s
     ✔ jobmanager Pulled                                                                                             129.9s
    [+] Running 3/4
     - Network flinkdata_default          Created                                                                      1.5s
     ✔ Container flinkdata-jobmanager-1   Started                                                                      0.8s
     ✔ Container flinkdata-taskmanager-2  Started                                                                      1.2s
     ✔ Container flinkdata-taskmanager-1  Started                                                                      0.8s

    控制台查看:

  • 相关阅读:
    通过ELO机制衡量各类对弈活动水平
    MyBatis的关联映射
    健壮性测试是什么?
    「数据结构详解·三」栈
    SAP STMS请求重复传输
    idea 启动安卓项目,模拟器点击无反应
    Java测试复盘(五)
    PHP M题 20221104
    服装店收银系统一套多少钱?(带服装店进销存管理系统)
    红外测温传感器MLX90614
  • 原文地址:https://blog.csdn.net/frinder/article/details/137357393