Revert "Mofiy e2e log checks for checkpoint restore"

This reverts commit 69e0ce8.

Author: gyfora

e2e-tests/test_application_kubernetes_ha.sh

@@ -42,7 +42,7 @@ echo "Kill the $jm_pod_name"
 kubectl exec $jm_pod_name -c flink-main-container -- /bin/sh -c "kill 1"
 
 # Check the new JobManager recovering from latest successful checkpoint
-wait_for_logs $jm_pod_name "Restoring job $job_id from .*chk" ${TIMEOUT} || exit 1
+wait_for_logs $jm_pod_name "Restoring job $job_id from Checkpoint" ${TIMEOUT} || exit 1
 wait_for_logs $jm_pod_name "Completed checkpoint [0-9]+ for job" ${TIMEOUT} || exit 1
 wait_for_status flinkdep/flink-example-statemachine '.status.jobManagerDeploymentStatus' READY ${TIMEOUT} || exit 1
 wait_for_status flinkdep/flink-example-statemachine '.status.jobStatus.state' RUNNING ${TIMEOUT} || exit 1

e2e-tests/test_application_operations.sh

@@ -61,7 +61,7 @@ wait_for_jobmanager_running $CLUSTER_ID $TIMEOUT
 jm_pod_name=$(get_jm_pod_name $CLUSTER_ID)
 
 # Check the new JobManager recovering from latest successful checkpoint
-wait_for_logs $jm_pod_name "Restoring job $job_id from .*chk" ${TIMEOUT} || exit 1
+wait_for_logs $jm_pod_name "Restoring job $job_id from Checkpoint" ${TIMEOUT} || exit 1
 wait_for_logs $jm_pod_name "Completed checkpoint [0-9]+ for job" ${TIMEOUT} || exit 1
 wait_for_status flinkdep/flink-example-statemachine '.status.jobManagerDeploymentStatus' READY ${TIMEOUT} || exit 1
 wait_for_status flinkdep/flink-example-statemachine '.status.jobStatus.state' RUNNING ${TIMEOUT} || exit 1

e2e-tests/test_sessionjob_kubernetes_ha.sh

@@ -43,7 +43,7 @@ echo "Kill the $jm_pod_name"
 kubectl exec $jm_pod_name -c flink-main-container -- /bin/sh -c "kill 1"
 
 # Check the new JobManager recovering from latest successful checkpoint
-wait_for_logs $jm_pod_name "Restoring job $job_id from .*chk" ${TIMEOUT} || exit 1
+wait_for_logs $jm_pod_name "Restoring job $job_id from Checkpoint" ${TIMEOUT} || exit 1
 wait_for_logs $jm_pod_name "Completed checkpoint [0-9]+ for job" ${TIMEOUT} || exit 1
 wait_for_status $SESSION_CLUSTER_IDENTIFIER '.status.jobManagerDeploymentStatus' READY ${TIMEOUT} || exit 1
 wait_for_status $SESSION_JOB_IDENTIFIER '.status.jobStatus.state' RUNNING ${TIMEOUT} || exit 1