Fix issue if job manager restart and task is already present.

2021-01-22 16:38:50 +07:00 · 2021-01-22 16:38:50 +07:00 · 44d0f5c4ac
parent 1ccf806bc5
commit 44d0f5c4ac
1 changed files with 4 additions and 1 deletions
--- a/pinpoint-flink/docker-bin/docker-entrypoint.sh
+++ b/pinpoint-flink/docker-bin/docker-entrypoint.sh
@ -13,7 +13,10 @@ if [ "$1" = "standalone-job" ]; then

  /docker-entrypoint.sh jobmanager &
  sleep 5
-  exec flink run $@
+  if ! flink list | grep 'RUNNING'; then
+    flink run $@
+  fi
+  wait
 else
  exec /docker-entrypoint.sh $@
 fi