From ffec118a56045eec26fda7dd528975ab426de3fa Mon Sep 17 00:00:00 2001 From: zeekling Date: Sat, 17 Sep 2022 19:06:19 +0800 Subject: [PATCH] update --- flink/build.sh | 11 ++++++----- flink/restart.sh | 5 +++++ 2 files changed, 11 insertions(+), 5 deletions(-) create mode 100755 flink/restart.sh diff --git a/flink/build.sh b/flink/build.sh index af3cc39..af95f3a 100755 --- a/flink/build.sh +++ b/flink/build.sh @@ -1,6 +1,7 @@ #!/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 rm jobmanager @@ -10,11 +11,11 @@ docker rm taskmanager FLINK_PROPERTIES="jobmanager.rpc.address: jobmanager" docker run -dit --name="jobmanager" \ - --network flink-network -p 8081:8081 \ + --detach -p 8081:8081 \ --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \ - flink:scala_2.12-java8 jobmanager + flink:1.15-scala_2.12-java8 jobmanager docker run -dit --name="taskmanager" \ - --network flink-network \ + --detach \ --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \ - flink:scala_2.12-java8 taskmanager + flink:1.15-scala_2.12-java8 taskmanager diff --git a/flink/restart.sh b/flink/restart.sh new file mode 100755 index 0000000..6a6e3e8 --- /dev/null +++ b/flink/restart.sh @@ -0,0 +1,5 @@ +#!/usr/bin/env bash + +docker restart jobmanager +docker restart taskmanager +