From a9c323c81d466668b1d344d067226bbf3d9df59c Mon Sep 17 00:00:00 2001
From: Charles DELFLY <c.delfly@linkbynet.com>
Date: Fri, 22 Jan 2021 16:38:50 +0700
Subject: [PATCH] Fix issue if job manager restart and task is already present.

---
 pinpoint-flink/docker-bin/docker-entrypoint.sh | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/pinpoint-flink/docker-bin/docker-entrypoint.sh b/pinpoint-flink/docker-bin/docker-entrypoint.sh
index 67676ee..695dd18 100755
--- 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
\ No newline at end of file