This commit is contained in:
LingZhaoHui 2022-09-17 19:06:19 +08:00
parent 7e4ab29a48
commit ffec118a56
2 changed files with 11 additions and 5 deletions

View File

@ -1,6 +1,7 @@
#!/usr/bin/env bash #!/usr/bin/env bash
docker pull flink:scala_2.12-java8 #docker pull flink:scala_2.12-java8
# docker pull flink:1.15-scala_2.12-java8
docker stop jobmanager docker stop jobmanager
docker rm jobmanager docker rm jobmanager
@ -10,11 +11,11 @@ docker rm taskmanager
FLINK_PROPERTIES="jobmanager.rpc.address: jobmanager" FLINK_PROPERTIES="jobmanager.rpc.address: jobmanager"
docker run -dit --name="jobmanager" \ docker run -dit --name="jobmanager" \
--network flink-network -p 8081:8081 \ --detach -p 8081:8081 \
--env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \ --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
flink:scala_2.12-java8 jobmanager flink:1.15-scala_2.12-java8 jobmanager
docker run -dit --name="taskmanager" \ docker run -dit --name="taskmanager" \
--network flink-network \ --detach \
--env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \ --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
flink:scala_2.12-java8 taskmanager flink:1.15-scala_2.12-java8 taskmanager

5
flink/restart.sh Executable file
View File

@ -0,0 +1,5 @@
#!/usr/bin/env bash
docker restart jobmanager
docker restart taskmanager