From bd671d06dc0fddd9fbbb78f7b0632202f528a120 Mon Sep 17 00:00:00 2001 From: zhoukunhua Date: Fri, 24 Jun 2022 11:54:02 +0800 Subject: [PATCH] . --- .gitignore | 13 +++++++++++++ README.md | 9 +++++++++ docker-compose.yml | 40 ++++++++++++++++++++++++++++++++++++++++ 3 files changed, 62 insertions(+) create mode 100644 .gitignore create mode 100644 README.md create mode 100644 docker-compose.yml diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..28fdcbd --- /dev/null +++ b/.gitignore @@ -0,0 +1,13 @@ +/.idea/ + +/flink/flink-checkpoints/** +!/flink/flink-checkpoints/.gitkeeper + +/flink/flink-savepoints/** +!/flink/flink-savepoints/.gitkeeper + +/flink/log/** +!/flink/log/.gitkeeper + +/flink/runjob/** +!/flink/runjob/.gitkeeper \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000..b4eaeef --- /dev/null +++ b/README.md @@ -0,0 +1,9 @@ +# flink-docker-example + +#### 介绍 + +使用docker-compose启动flink，方便本地开发。 + +#### 使用说明 + +命令行运行 docker-compose up -d \ No newline at end of file diff --git a/docker-compose.yml b/docker-compose.yml new file mode 100644 index 0000000..cac1863 --- /dev/null +++ b/docker-compose.yml @@ -0,0 +1,40 @@ +version: '3' +services: + jobmanager: + image: flink:1.15-java8 + expose: + - "6123" + ports: + - "8081:8081" + command: jobmanager + volumes: + - ./flink/flink-checkpoints:/opt/flink/flink-checkpoints + - ./flink/flink-savepoints:/opt/flink/flink-savepoints + - ./flink/log:/opt/flink/log + - ./flink/runjob:/opt/flink/usrlib + environment: + - TZ=Asia/Shanghai + - JOB_MANAGER_RPC_ADDRESS=jobmanager + extra_hosts: + - "kafka1:192.168.10.217" + - "kafka2:192.168.10.217" + taskmanager: + image: flink:1.15-java8 + expose: + - "6121" + - "6122" + depends_on: + - jobmanager + command: taskmanager + - ./flink/flink-checkpoints:/opt/flink/flink-checkpoints + - ./flink/flink-savepoints:/opt/flink/flink-savepoints + - ./flink/log:/opt/flink/log + - ./flink/runjob:/opt/flink/usrlib + links: + - "jobmanager:jobmanager" + environment: + - TZ=Asia/Shanghai + - JOB_MANAGER_RPC_ADDRESS=jobmanager + extra_hosts: + - "kafka1:192.168.10.217" + - "kafka2:192.168.10.217" \ No newline at end of file