From f47e33d0b2ed39f6de100b6ac42422bb8b58e2ae Mon Sep 17 00:00:00 2001
From: sv3ndk <svend.vanderveken@gmail.com>
Date: Tue, 13 Apr 2021 17:35:23 +0200
Subject: [PATCH] adds connection timeout to job submitter

---
 controllers/flinkcluster_submit_job_script.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/controllers/flinkcluster_submit_job_script.go b/controllers/flinkcluster_submit_job_script.go
index 59ee9780..a86bf653 100644
--- a/controllers/flinkcluster_submit_job_script.go
+++ b/controllers/flinkcluster_submit_job_script.go
@@ -57,8 +57,8 @@ function check_jm_ready() {
 
     echo_log "Checking job manager to be ready. Will check success of ${REQUIRED_SUCCESS_NUMBER} API calls for stable job submission." "job_check_log"
     for ((i = 1; i <= MAX_RETRY; i++)); do
-        echo_log "curl -sS \"http://${FLINK_JM_ADDR}/jobs\"" "job_check_log"
-        if curl -sS "http://${FLINK_JM_ADDR}/jobs" 2>&1 | tee -a job_check_log; then
+        echo_log "curl -sS --connect-timeout 5 \"http://${FLINK_JM_ADDR}/jobs\"" "job_check_log"
+        if curl -sS --connect-timeout 5 "http://${FLINK_JM_ADDR}/jobs" 2>&1 | tee -a job_check_log; then
             ((success_count++))
             echo_log "\nSuccess ${success_count}/${REQUIRED_SUCCESS_NUMBER}" "job_check_log"
             if ((success_count < REQUIRED_SUCCESS_NUMBER)); then