### 使用 `docker-compose.yml` 配置 Flink 参数 在使用 Docker Compose 部署 Flink 时，可以通过编辑 `docker-compose.yml` 文件中的服务定义来设置各种参数。这包括但不限于 JobManager 和 TaskManager 的资源配置、环境变量传递以及挂载外部卷等操作。 #### 1. 定义基本的服务结构 首先，在 `docker-compose.yml` 中需要分别定义用于启动 JobManager 和 TaskManager 的服务实例。通常情况下会有一个名为 `jobmanager` 的服务负责管理整个集群的任务调度逻辑，而另一个或多个命名为 `taskmanager` 的服务则用来处理具体的计算任务[^1]。 ```yaml version: '3' services: jobmanager: image: flink:latest ports: - "8081:8081" command: jobmanager environment: - JOB_MANAGER_RPC_ADDRESS=jobmanager volumes: - ./config:/opt/flink/conf taskmanager: image: flink:latest depends_on: - jobmanager command: taskmanager environment: - JOB_MANAGER_RPC_ADDRESS=jobmanager deploy: replicas: 2 ``` 以上片段展示了最基础的一个配置例子，其中设置了两个副本的 TaskManagers 来模拟小型分布式环境。 #### 2. 设置自定义参数 对于更复杂的场景可能还需要额外定制一些行为特性，比如调整内存限制或者启用特定插件等功能都可以借助于添加合适的命令行标志或者是修改对应位置上的 XML/YAML 文档形式表达出来的属性列表来进行实现[^3]。 - **通过 Command 字段传入 CLI Options** 如果某些选项仅需临时生效而不必永久保存的话可以直接利用 service 下面的 `command` 属性追加必要的开关项给目标镜像执行入口点调用即可[^1]。 ```yaml ... taskmanager: ... command: ["taskmanager", "-Dparallelism.default=4"] ``` - **Environment Variables** 很多时候我们也会依赖系统级别的全局设定去影响程序内部的工作模式，这时就可以考虑采用 ENVIRONMENTS 方法向容器注入相关信息源以便后续解析应用[^2]。 ```yaml ... taskmanager: ... environment: - FLINK_ENV_JAVA_OPTS=-Xms512m -Xmx2g ``` - **Mount Configurations** 对于那些经常变动又不想每次都重新打包新版本的情况而言，合理运用 VOLUMES 功能显得尤为重要——它允许我们将主机路径映射到容器内的某个固定地址处形成共享关系，这样一来无论何时只要更新了本地文件夹里的内容就能立即反映出来无需重启任何东西。 ```yaml ... jobmanager: ... volumes: - ./my-flink-conf.yaml:/opt/flink/conf/flink-conf.yaml ``` #### 3. 启动与验证 最后一步自然是按照常规流程拉取最新镜像之后再依据当前项目根目录下调用 `docker-compose up -d` 命令后台运行所有关联起来的服务单元[^1]。接着打开浏览器访问 http://localhost:8081 地址应该可以看到 Web UI 页面呈现出来了代表成功构建出了一个简易版的 Apache Flink 测试平台！ --- ###