[flink-statefun] branch master updated (3f4cddc -> 2ceb374)

[sj...@apache.org]

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

sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.


    from 3f4cddc  [hotfix] Add missing configurations to flink session cluster deployment
     add 0e33e4a  [FLINK-17193] [python-k8s-example] Redirect helm template output to file.
     new 2ceb374  [FLINK-17193] [python-k8s-example] Abort script on failure. Build SDK distribution if was not previously built

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../statefun-python-k8s-example/build-example.sh      | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

[flink-statefun] 01/01: [FLINK-17193] [python-k8s-example] Abort script on failure. Build SDK distribution if was not previously built

[sj...@apache.org]

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

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

commit 2ceb3742dce6c7ef858e52db7aec2f9e5c4ac71d
Author: Rafi Aroch <ra...@gmail.com>
AuthorDate: Thu Apr 16 21:37:48 2020 +0300

    [FLINK-17193] [python-k8s-example] Abort script on failure. Build SDK distribution if was not previously built
    
    This closes #99
---
 .../statefun-python-k8s-example/build-example.sh        | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/statefun-examples/statefun-python-k8s-example/build-example.sh b/statefun-examples/statefun-python-k8s-example/build-example.sh
index a079234..d7095f6 100755
--- a/statefun-examples/statefun-python-k8s-example/build-example.sh
+++ b/statefun-examples/statefun-python-k8s-example/build-example.sh
@@ -1,4 +1,7 @@
 #!/bin/bash
+
+set -e
+
 #
 # Licensed to the Apache Software Foundation (ASF) under one or more
 # contributor license agreements.  See the NOTICE file distributed with
@@ -20,19 +23,21 @@ PYTHON_SERVICE_NAME="python-worker"
 STATEFUN_IMAGE_NAME="k8s-demo-statefun"
 PARALLELISM=3
 K8S_RESOURCES_YAML="k8s-demo.yaml"
+SDK_DISTRIBUTION_WHL_PATH="../../statefun-python-sdk/dist/apache_flink_statefun-*-py3-none-any.whl"
 
 # clean
 rm -f apache_flink_statefun-*-py3-none-any.whl
 rm -rf __pycache__
 
-# copy the whl distribution, it must be first built by calling build-distribution.sh 
-cp ../../statefun-python-sdk/dist/apache_flink_statefun-*-py3-none-any.whl apache_flink_statefun-snapshot-py3-none-any.whl 2>/dev/null
-rc=$?
-if [[ ${rc} -ne 0 ]]; then
-    echo "Failed copying the whl distribution, please build the distribution first by calling ./build-distribution.sh" 
-    exit 1;
+if [ ! -f ${SDK_DISTRIBUTION_WHL_PATH} ]; then
+    echo "SDK distribution has to be built first. Building it"
+    pushd ../../statefun-python-sdk
+    ./build-distribution.sh
+    popd
 fi
 
+cp ${SDK_DISTRIBUTION_WHL_PATH} apache_flink_statefun-snapshot-py3-none-any.whl 2>/dev/null
+
 # build the flask container
 docker build -f Dockerfile.python-worker . -t ${PYTHON_IMAGE_NAME}