[flink] branch release-1.6 updated: [FLINK-10910][e2e] Hardened Kubernetes e2e test.

[dw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.6 by this push:
     new 01e3c72  [FLINK-10910][e2e] Hardened Kubernetes e2e test.
01e3c72 is described below

commit 01e3c7273f4c4a37524f870f08e2cea05281e963
Author: Dawid Wysakowicz <wy...@gmail.com>
AuthorDate: Wed Jan 30 11:42:22 2019 +0100

    [FLINK-10910][e2e] Hardened Kubernetes e2e test.
    
    Added check if minikube is running. If it is not we try to start it couple of times. If we do not succeed we fail with a descriptive message.
---
 .../test-scripts/test_kubernetes_embedded_job.sh    | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

diff --git a/flink-end-to-end-tests/test-scripts/test_kubernetes_embedded_job.sh b/flink-end-to-end-tests/test-scripts/test_kubernetes_embedded_job.sh
index 4529fd9..96320fd 100755
--- a/flink-end-to-end-tests/test-scripts/test_kubernetes_embedded_job.sh
+++ b/flink-end-to-end-tests/test-scripts/test_kubernetes_embedded_job.sh
@@ -22,6 +22,8 @@ source "$(dirname "$0")"/common.sh
 DOCKER_MODULE_DIR=${END_TO_END_DIR}/../flink-container/docker
 KUBERNETES_MODULE_DIR=${END_TO_END_DIR}/../flink-container/kubernetes
 CONTAINER_SCRIPTS=${END_TO_END_DIR}/test-scripts/container-scripts
+MINIKUBE_START_RETRIES=3
+MINIKUBE_START_BACKOFF=5
 
 export FLINK_JOB=org.apache.flink.examples.java.wordcount.WordCount
 export FLINK_IMAGE_NAME=test_kubernetes_embedded_job
@@ -37,10 +39,29 @@ function cleanup {
     rm -rf ${OUTPUT_VOLUME}
 }
 
+function check_kubernetes_status {
+    local status=`minikube status`
+    echo ${status} | grep -q "minikube: Running cluster: Running kubectl: Correctly Configured"
+    return $?
+}
+
+function start_kubernetes_if_not_running {
+    if ! check_kubernetes_status; then
+        minikube start
+    fi
+
+    return $(check_kubernetes_status)
+}
+
 trap cleanup EXIT
 
 mkdir -p $OUTPUT_VOLUME
 
+if ! retry_times ${MINIKUBE_START_RETRIES} ${MINIKUBE_START_BACKOFF} start_kubernetes_if_not_running; then
+    echo "Minikube not running. Could not start minikube. Aborting..."
+    exit 1
+fi
+
 eval $(minikube docker-env)
 cd "$DOCKER_MODULE_DIR"
 ./build.sh --from-local-dist --job-jar ${FLINK_DIR}/examples/batch/WordCount.jar --image-name ${FLINK_IMAGE_NAME}