This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit f44513693d6a93af60584fa10f9fd6fb5b088869 Author: Matthias Pohl <[email protected]> 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 24ffc59..489b6e0 100755 --- a/flink-end-to-end-tests/test-scripts/test_pyflink.sh +++ b/flink-end-to-end-tests/test-scripts/test_pyflink.sh @@ -253,16 +253,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 \ @@ -308,9 +298,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
