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 <[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 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
