.

3 years ago · bd671d06dc
3 changed files with 62 additions and 0 deletions
--- a/.gitignore
+++ 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
--- a/README.md
+++ b/README.md
@ -0,0 +1,9 @@
+# flink-docker-example
+
+#### 介绍
+
+使用docker-compose启动flink，方便本地开发。
+
+#### 使用说明
+
+命令行运行 docker-compose up -d
--- a/docker-compose.yml
+++ 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"