[flink] 01/02: [FLINK-26105][e2e] Removes printing of logs to stdout for pyflink_test

[ma...@apache.org]

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

mapohl pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 075c65da9813e2302f5dda63e0e738583e3f3ce2
Author: Matthias Pohl <ma...@ververica.com>
AuthorDate: Thu Feb 17 13:18:17 2022 +0100

    [FLINK-26105][e2e] Removes printing of logs to stdout for pyflink_test
    
    I removed the test_pyflink.sh to align it with how errors are
    handled in other e2e tests. The logs are accessible through the
    build artifacts and shouldn't spill into stdout. The rolling
    filenames in flink might lead to a strange ordering anyway.
---
 flink-end-to-end-tests/test-scripts/test_pyflink.sh | 14 --------------
 1 file changed, 14 deletions(-)

diff --git a/flink-end-to-end-tests/test-scripts/test_pyflink.sh b/flink-end-to-end-tests/test-scripts/test_pyflink.sh
index 74c00bf..630e5f9 100755
--- a/flink-end-to-end-tests/test-scripts/test_pyflink.sh
+++ b/flink-end-to-end-tests/test-scripts/test_pyflink.sh
@@ -221,16 +221,6 @@ function read_msg_from_kafka {
     --consumer-property group.id=$3 --timeout-ms 90000 2> /dev/null
 }
 
-function cat_jm_logs {
-     local log_file_name=${3:-standalonesession}
-     cat $FLINK_LOG_DIR/*$log_file_name*.log
-}
-
-function cat_tm_logs {
-	local logfile="$FLINK_LOG_DIR/flink*taskexecutor*log"
-	cat ${logfile}
-}
-
 send_msg_to_kafka "${PAYMENT_MSGS[*]}"
 
 JOB_ID=$(${FLINK_DIR}/bin/flink run \
@@ -276,9 +266,5 @@ if [[ "${EXPECTED_MSG[*]}" != "${SORTED_READ_MSG[*]}" ]]; then
     echo "Output from Flink program does not match expected output."
     echo -e "EXPECTED Output: --${EXPECTED_MSG[*]}--"
     echo -e "ACTUAL: --${SORTED_READ_MSG[*]}--"
-    jm_log=$(cat_jm_logs)
-    echo "JobManager logs: " ${jm_log}
-    tm_log=$(cat_tm_logs)
-    echo "TaskManager logs: " ${tm_log}
     exit 1
 fi