[flink-kubernetes-operator] 01/02: [tests] Improve e2e to validate upgrade after scaling

[gy...@apache.org]

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

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

commit 68348d64b8f55c1c712ab4563038e90e7faaea2a
Author: Gyula Fora <g_...@apple.com>
AuthorDate: Wed Aug 9 14:16:59 2023 +0200

    [tests] Improve e2e to validate upgrade after scaling
---
 e2e-tests/data/autoscaler.yaml | 2 +-
 e2e-tests/test_autoscaler.sh   | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/e2e-tests/data/autoscaler.yaml b/e2e-tests/data/autoscaler.yaml
index ce41f325..e94227cf 100644
--- a/e2e-tests/data/autoscaler.yaml
+++ b/e2e-tests/data/autoscaler.yaml
@@ -71,7 +71,7 @@ spec:
   job:
     jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar
     parallelism: 2
-    upgradeMode: last-state
+    upgradeMode: savepoint
   mode: native
 
 ---
diff --git a/e2e-tests/test_autoscaler.sh b/e2e-tests/test_autoscaler.sh
index 49767d64..100f9484 100644
--- a/e2e-tests/test_autoscaler.sh
+++ b/e2e-tests/test_autoscaler.sh
@@ -46,6 +46,7 @@ else
   echo "Verifying inplace scaling triggered"
   wait_for_event FlinkDeployment $CLUSTER_ID .reason==\"Scaling\" ${TIMEOUT} || exit 1
 fi
+wait_for_status $APPLICATION_IDENTIFIER '.status.jobStatus.state' RUNNING ${TIMEOUT} || exit 1
 wait_for_status $APPLICATION_IDENTIFIER '.status.lifecycleState' STABLE ${TIMEOUT} || exit 1
 
 check_operator_log_for_errors || exit 1