This is an automated email from the ASF dual-hosted git repository.
gaborgsomogyi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new 31d01f24 [FLINK-34198] Remove e2e test operator log error check
31d01f24 is described below
commit 31d01f246d8a344b560aab1653b7aba561baea26
Author: Gabor Somogyi <[email protected]>
AuthorDate: Mon Jan 22 17:33:07 2024 +0100
[FLINK-34198] Remove e2e test operator log error check
---
e2e-tests/test_application_kubernetes_ha.sh | 2 --
e2e-tests/test_application_operations.sh | 2 --
e2e-tests/test_autoscaler.sh | 2 --
e2e-tests/test_multi_sessionjob.sh | 2 --
e2e-tests/test_sessionjob_kubernetes_ha.sh | 2 --
e2e-tests/test_sessionjob_operations.sh | 2 --
e2e-tests/utils.sh | 31 -----------------------------
7 files changed, 43 deletions(-)
diff --git a/e2e-tests/test_application_kubernetes_ha.sh
b/e2e-tests/test_application_kubernetes_ha.sh
index 3c1a4d82..1797b29a 100755
--- a/e2e-tests/test_application_kubernetes_ha.sh
+++ b/e2e-tests/test_application_kubernetes_ha.sh
@@ -47,7 +47,5 @@ wait_for_logs $jm_pod_name "Completed checkpoint [0-9]+ for
job" ${TIMEOUT} || e
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
-check_operator_log_for_errors '|grep -v "REST service in session cluster timed
out"' || exit 1
-
echo "Successfully run the Flink Kubernetes application HA test"
diff --git a/e2e-tests/test_application_operations.sh
b/e2e-tests/test_application_operations.sh
index d69da980..22e2d179 100755
--- a/e2e-tests/test_application_operations.sh
+++ b/e2e-tests/test_application_operations.sh
@@ -67,6 +67,4 @@ wait_for_status flinkdep/flink-example-statemachine
'.status.jobManagerDeploymen
wait_for_status flinkdep/flink-example-statemachine '.status.jobStatus.state'
RUNNING ${TIMEOUT} || exit 1
assert_available_slots 1 $CLUSTER_ID
-check_operator_log_for_errors || exit 1
-
echo "Successfully run the last-state upgrade test"
diff --git a/e2e-tests/test_autoscaler.sh b/e2e-tests/test_autoscaler.sh
index 49767d64..4afa952b 100644
--- a/e2e-tests/test_autoscaler.sh
+++ b/e2e-tests/test_autoscaler.sh
@@ -48,6 +48,4 @@ else
fi
wait_for_status $APPLICATION_IDENTIFIER '.status.lifecycleState' STABLE
${TIMEOUT} || exit 1
-check_operator_log_for_errors || exit 1
-
echo "Successfully run the autoscaler test"
diff --git a/e2e-tests/test_multi_sessionjob.sh
b/e2e-tests/test_multi_sessionjob.sh
index 09862db5..59990870 100755
--- a/e2e-tests/test_multi_sessionjob.sh
+++ b/e2e-tests/test_multi_sessionjob.sh
@@ -38,7 +38,6 @@ jm_pod_name=$(get_jm_pod_name $CLUSTER_ID)
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
-check_operator_log_for_errors || exit 1
echo "Flink Session Job is running properly"
# Current namespace: flink
@@ -49,5 +48,4 @@ jm_pod_name=$(get_jm_pod_name $CLUSTER_ID)
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
-check_operator_log_for_errors || exit 1
echo "Flink Session Job is running properly"
diff --git a/e2e-tests/test_sessionjob_kubernetes_ha.sh
b/e2e-tests/test_sessionjob_kubernetes_ha.sh
index 37c8c37e..0ad55b12 100755
--- a/e2e-tests/test_sessionjob_kubernetes_ha.sh
+++ b/e2e-tests/test_sessionjob_kubernetes_ha.sh
@@ -48,7 +48,5 @@ wait_for_logs $jm_pod_name "Completed checkpoint [0-9]+ for
job" ${TIMEOUT} || e
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
-check_operator_log_for_errors '|grep -v "REST service in session cluster timed
out"' || exit 1
-
echo "Successfully run the Flink Session Job HA test"
diff --git a/e2e-tests/test_sessionjob_operations.sh
b/e2e-tests/test_sessionjob_operations.sh
index c230af8c..b1c88fc2 100755
--- a/e2e-tests/test_sessionjob_operations.sh
+++ b/e2e-tests/test_sessionjob_operations.sh
@@ -79,5 +79,3 @@ wait_for_jobmanager_running $CLUSTER_ID $TIMEOUT
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
-
-check_operator_log_for_errors || exit 1
diff --git a/e2e-tests/utils.sh b/e2e-tests/utils.sh
index 7f5513c5..e3f5b741 100755
--- a/e2e-tests/utils.sh
+++ b/e2e-tests/utils.sh
@@ -184,37 +184,6 @@ function patch_flink_config() {
kubectl patch cm flink-operator-config -n "${operator_pod_namespace}" --type
merge -p "${patch}"
}
-function check_operator_log_for_errors {
- local ignore=$1
- echo "Checking for operator log errors..."
- #https://issues.apache.org/jira/browse/FLINK-30310
- echo "Error checking is temporarily turned off."
- return 0
-
- operator_pod_namespace=$(get_operator_pod_namespace)
- operator_pod_name=$(get_operator_pod_name)
- echo "Operator namespace: ${operator_pod_namespace} pod:
${operator_pod_name}"
-
- local cmd="kubectl logs -n ${operator_pod_namespace} ${operator_pod_name}
- | grep -e '\[\s*ERROR\s*\]'
- | grep -v 'Failed to submit a listener notification task'
`#https://issues.apache.org/jira/browse/FLINK-30147`
- | grep -v 'Failed to submit job to session cluster'
`#https://issues.apache.org/jira/browse/FLINK-30148`
- | grep -v 'Error during event processing'
`#https://issues.apache.org/jira/browse/FLINK-30149`
- | grep -v 'Error while patching status'
`#https://issues.apache.org/jira/browse/FLINK-30283`
- ${ignore}"
-
- echo "Filter command: ${cmd}"
- errors=$(eval ${cmd} || true)
-
- if [ -z "${errors}" ]; then
- echo "No errors in log files."
- return 0
- else
- echo -e "Found error in log files.\n\n${errors}"
- return 1
- fi
-}
-
function debug_and_show_logs {
echo "Debugging failed e2e test:"
echo "Currently existing Kubernetes resources"
