-
Notifications
You must be signed in to change notification settings - Fork 48
/
Copy pathdocker-compose.yml
63 lines (60 loc) · 1.43 KB
/
docker-compose.yml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
version: '3.4'
services:
jobmanager:
image: flink:1.7.2-scala_2.11
ports:
- "8081:8081"
- "6123:6123"
command: jobmanager
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
volumes:
- /tmp/flink-deployer:/data/flink
taskmanager:
image: flink:1.7.2-scala_2.11
depends_on:
- jobmanager
command: taskmanager
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
volumes:
- /tmp/flink-deployer:/data/flink
deployer:
build: .
image: nielsdenissen/flink-deployer:master
depends_on:
- jobmanager
- taskmanager
# Deploy
command:
- "deploy"
- "--file-name"
- "/tmp/flink-stateful-wordcount-assembly-0.jar"
- "--entry-class"
- "WordCountStateful"
- "--parallelism"
- "2"
- "--program-args"
- "--intervalMs 1000"
# Update
# command:
# - "update"
# - "--job-name-base"
# - "Windowed WordCount"
# - "--file-name"
# - "/tmp/flink-stateful-wordcount-assembly-0.jar"
# - "--entry-class"
# - "WordCountStateful"
# - "--parallelism"
# - "2"
# - "--program-args"
# - "--intervalMs 1000"
# - "--savepoint-dir"
# - "/data/flink"
volumes:
- /tmp/flink-deployer:/data/flink
- ./flink-sample-job/target/scala-2.11/:/tmp
environment:
- FLINK_BASE_URL=http://jobmanager:8081
links:
- jobmanager