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

2021-01-22 16:38:50 +07:00
parent 744a748e81
commit a9c323c81d
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