File tree 2 files changed +40
-0
lines changed
2 files changed +40
-0
lines changed Original file line number Diff line number Diff line change
1
+ FROM flink:scala_2.12-java11
2
+ RUN mkdir -p $FLINK_HOME/usrlib
3
+ COPY --chown=flink:flink target/application.jar $FLINK_HOME/usrlib/application.jar
Original file line number Diff line number Diff line change
1
+ version : ' 3.5'
2
+
3
+ services :
4
+ jobmanager :
5
+ platform : linux/x86_64
6
+ image : flink:1.14.6-scala_2.12-java11
7
+ hostname : jobmanager
8
+ container_name : jobmanager
9
+ command : standalone-job --job-classname com.joel.FlinkJob
10
+ restart : always
11
+ ports :
12
+ - " 8081:8081"
13
+ - " 9464:9464"
14
+ environment :
15
+ - |
16
+ FLINK_PROPERTIES=
17
+ env.java.opts: -javaagent:/opt/flink/lib/opentelemetry-javaagent.jar -Dotel.javaagent.debug=false -Dotel.metrics.exporter=prometheus -Dotel.instrumentation.aws-sdk.enabled=true
18
+ jobmanager.rpc.address: jobmanager
19
+ parallelism.default: 2
20
+ taskmanager :
21
+ platform : linux/x86_64
22
+ image : flink:1.14.6-scala_2.12-java11
23
+ hostname : taskmanager
24
+ container_name : taskmanager
25
+ command : taskmanager
26
+ depends_on :
27
+ - jobmanager
28
+ restart : always
29
+ ports :
30
+ - " 9465:9464"
31
+ environment :
32
+ - |
33
+ FLINK_PROPERTIES=
34
+ env.java.opts: -javaagent:/opt/flink/lib/opentelemetry-javaagent.jar -Dotel.javaagent.debug=false -Dotel.metrics.exporter=prometheus -Dotel.instrumentation.aws-sdk.enabled=true
35
+ jobmanager.rpc.address: jobmanager
36
+ taskmanager.numberOfTaskSlots: 6
37
+ parallelism.default: 2
You can’t perform that action at this time.
0 commit comments