Updating the B/G e2e tests

Author: schongloo

e2e-tests/test_bluegreen_laststate.sh

@@ -52,10 +52,15 @@ wait_for_status $APPLICATION_IDENTIFIER '.status.blueGreenState' ACTIVE_BLUE ${T
 
 #blue_job_id=$(kubectl get -oyaml flinkdep/basic-bluegreen-example-blue | yq '.status.jobStatus.jobId')
 
+#kubectl patch flinkbgdep ${BG_CLUSTER_ID} --type merge --patch '{"spec":{"template":{"spec":{"flinkConfiguration":{"rest.port":"8082","state.checkpoints.num-retained":"6"}}}}}'
 kubectl patch flinkbgdep ${BG_CLUSTER_ID} --type merge --patch '{"spec":{"template":{"spec":{"flinkConfiguration":{"state.checkpoints.num-retained":"6"}}}}}'
 echo "Resource patched, giving a chance for the savepoint to be taken..."
 sleep 10
 
+jm_pod_name=$(get_jm_pod_name $BLUE_CLUSTER_ID)
+echo "Inspecting savepoint directory..."
+kubectl exec -it $jm_pod_name -- bash -c "ls -lt /opt/flink/volume/flink-sp/"
+
 wait_for_status $GREEN_APPLICATION_IDENTIFIER '.status.lifecycleState' STABLE ${TIMEOUT} || exit 1
 kubectl wait --for=delete deployment --timeout=${TIMEOUT}s --selector="app=${BLUE_CLUSTER_ID}"
 wait_for_status $APPLICATION_IDENTIFIER '.status.jobStatus.state' RUNNING ${TIMEOUT} || exit 1
@@ -69,7 +74,7 @@ echo "Waiting for deployment to be deleted..."
 kubectl wait --for=delete flinkbluegreendeployments/$BG_CLUSTER_ID
 
 if [[ $green_initialSavepointPath == '/opt/flink/volume/flink-sp/savepoint-'* ]]; then
-  echo 'Green deployment started from the expected initialSavepointPath: ' $green_initialSavepointPath
+  echo 'Green deployment started from the expected initialSavepointPath:' $green_initialSavepointPath
 else
   echo 'Unexpected initialSavepointPath:' $green_initialSavepointPath
   exit 1