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

[dwysakowicz]

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

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


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

commit e0ee3e5c4bede32d89492a5bc3bd91accd13f46e
Author: Dawid Wysakowicz <wysakowicz.da...@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}