【发布时间】:2020-05-29 11:05:11
【问题描述】:
最近我用Docker-compose启动了一个flink集群。这是我的文件:
version: "2.1"
services:
jobmanager:
image: flink:1.9.2-scala_2.11
expose:
- "6123"
ports:
- "8081:8081"
command: jobmanager
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
taskmanager:
image: flink:1.9.2-scala_2.11
expose:
- "6121"
- "6122"
depends_on:
- jobmanager
command: taskmanager
links:
- "jobmanager:jobmanager"
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
我从“docker-compose up -d --scale taskmanager=3”开始分配 3 个任务管理器。 我已经通过了 WordCount Demo,当我在 bash 中输入一些单词时,没有出现错误。
【问题讨论】:
标签: docker apache-flink