参考文档
| 文档链接 | 说明 |
|---|---|
| https://www.cnblogs.com/apachecn/p/18203716 | |
| https://blog.csdn.net/weixin_44904816/article/details/147797869 |
代码示例gitcode地址
https://gitcode.com/yunting/flink-java-demo.git
安装
docker-compose.yml
kk.kk.kk.kk 改成对应kafka的host
es.es.es.es 改成对应es的host
version: '3.9'services:jobmanager:image: flink:2.1.1 container_name: flink-jmports:- "8081:8081" # WebUIcommand: jobmanagerenvironment:- JOB_MANAGER_RPC_ADDRESS=jobmanagernetworks:- flink-netextra_hosts: # 把 Kafka/ES 域名写死，防止容器解析不到- "kafka1:kk.kk.kk.kk"- "kafka2:kk.kk.kk.kk"- "kafka3:kk.kk.kk.kk"- "es:es.es.es.es"volumes:- ./flink-data:/opt/flink/datataskmanager:image: flink:2.1.1container_name: flink-tmdepends_on:- jobmanagercommand: taskmanagerenvironment:- JOB_MANAGER_RPC_ADDRESS=jobmanagernetworks:- flink-netextra_hosts:- "kafka1:kk.kk.kk.kk"- "kafka2:kk.kk.kk.kk"- "kafka3:kk.kk.kk.kk"- "es:es.es.es.es"volumes:- ./flink-data:/opt/flink/datanetworks:flink-net:external: true
启动
在存放docker-compose.yml目录下
docker network create flink-net
docker-compose up -d
运行
Flink docker容器截图
Flink webui截图
备注
webui页面可以点击按钮取消任务
取消任务命令
docker exec -it flink-jm ./bin/flink cancel dabd1075ba75d807f5da4a2c4bee0068