This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0d20a6d5b7dc4c2ea0567981ed8b08d278763d00
Author: wangyang0918 <danrtsey...@alibaba-inc.com>
AuthorDate: Thu Apr 2 18:00:58 2020 +0800
[FLINK-16921][e2e] Wait for rest endpoint up and then submit Flink job to
existing Kubernetes session
---
flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh
b/flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh
index 5140a87..0cfc633 100755
--- a/flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh
+++ b/flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh
@@ -57,13 +57,18 @@ kubectl create clusterrolebinding ${CLUSTER_ROLE_BINDING}
--clusterrole=edit --s
mkdir -p "$(dirname $LOCAL_OUTPUT_PATH)"
# Set the memory and cpu smaller than default, so that the jobmanager and
taskmanager pods could be allocated in minikube.
-"$FLINK_DIR"/bin/kubernetes-session.sh -Dkubernetes.cluster-id=${CLUSTER_ID} \
+OUTPUT=`"$FLINK_DIR"/bin/kubernetes-session.sh
-Dkubernetes.cluster-id=${CLUSTER_ID} \
-Dkubernetes.container.image=${FLINK_IMAGE_NAME} \
-Djobmanager.heap.size=512m \
-Dcontainerized.heap-cutoff-min=100 \
-Dkubernetes.jobmanager.cpu=0.5 \
-Dkubernetes.taskmanager.cpu=0.5 \
- -Dkubernetes.container-start-command-template="%java% %classpath% %jvmmem%
%jvmopts% %logging% %class% %args%"
+ -Dkubernetes.container-start-command-template="%java% %classpath% %jvmmem%
%jvmopts% %logging% %class% %args%"`
+
+echo "$OUTPUT"
+
+JOBMANAGER_URL=$(echo "$OUTPUT" | grep 'JobManager Web Interface: ' | awk
-F'JobManager Web Interface: ' '{print $2}')
+wait_rest_endpoint_up "${JOBMANAGER_URL}/taskmanagers" "Dispatcher"
"\{\"taskmanagers\":\[.*\]\}"
"$FLINK_DIR"/bin/flink run -e kubernetes-session \
-Dkubernetes.cluster-id=${CLUSTER_ID} \
