Debugging the Blue/Green e2e tests

Author: schongloo

e2e-tests/data/bluegreen-laststate.yaml

@@ -28,7 +28,7 @@ spec:
       image: flink:1.20
       flinkVersion: v1_20
       flinkConfiguration:
-        rest.port: "8081"
+#        rest.port: "8081"
         execution.checkpointing.interval: "10s"
         execution.checkpointing.storage: "filesystem"
         state.backend.incremental: "true"
@@ -59,7 +59,7 @@ spec:
                   claimName: flink-bg-laststate
       taskManager:
         resource:
-          memory: 2G
+          memory: 1G
           cpu: 1
       job:
         jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar

e2e-tests/data/bluegreen-stateless.yaml

@@ -28,7 +28,7 @@ spec:
       image: flink:1.20
       flinkVersion: v1_20
       flinkConfiguration:
-        rest.port: "8081"
+#        rest.port: "8081"
         taskmanager.numberOfTaskSlots: "1"
       serviceAccount: flink
       jobManager:
@@ -37,7 +37,7 @@ spec:
           cpu: 1
       taskManager:
         resource:
-          memory: 2G
+          memory: 1G
           cpu: 1
       job:
         jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar

e2e-tests/test_bluegreen_laststate.sh

@@ -64,7 +64,7 @@ kubectl exec -it $jm_pod_name -- bash -c "ls -lt /opt/flink/volume/flink-sp/"
 
 tm_pod_name=""
 for i in $(seq 1 4); do
-  echo "==="
+  echo "====="
   echo "LISTING PODS:"
   kubectl get pods
 
@@ -74,7 +74,7 @@ for i in $(seq 1 4); do
   fi
   kubectl logs $jm_pod_name -c flink-main-container
 
-  echo "---"
+  echo "--==--"
   if [ "$tm_pod_name" = "" ]; then
       tm_pod_name=$(kubectl get pods --selector="app=${GREEN_CLUSTER_ID},component=taskmanager" -o jsonpath='{..metadata.name}')
       echo "Set TM pod name:" $tm_pod_name

e2e-tests/test_bluegreen_stateless.sh

@@ -52,7 +52,7 @@ kubectl patch flinkbgdep ${BG_CLUSTER_ID} --type merge --patch '{"spec":{"templa
 jm_pod_name=""
 tm_pod_name=""
 for i in $(seq 1 4); do
-  echo "==="
+  echo "====="
   echo "LISTING PODS:"
   kubectl get pods
 
@@ -62,7 +62,7 @@ for i in $(seq 1 4); do
   fi
   kubectl logs $jm_pod_name -c flink-main-container
 
-  echo "---"
+  echo "--==--"
   if [ "$tm_pod_name" = "" ]; then
       tm_pod_name=$(kubectl get pods --selector="app=${GREEN_CLUSTER_ID},component=taskmanager" -o jsonpath='{..metadata.name}')
       echo "Set TM pod name:" $tm_pod_name