XComp commented on a change in pull request #18806:
URL: https://github.com/apache/flink/pull/18806#discussion_r808953718
##########
File path: flink-end-to-end-tests/test-scripts/test_pyflink.sh
##########
@@ -223,13 +223,23 @@ function read_msg_from_kafka {
}
function cat_jm_logs {
- local log_file_name=${3:-standalonesession}
- cat $FLINK_LOG_DIR/*$log_file_name*.log
+ cat_logs_in_order "standalonesession"
}
function cat_tm_logs {
- local logfile="$FLINK_LOG_DIR/flink*taskexecutor*log"
Review comment:
@zentol When preparing the backports I noticed that I missed a few
occurrences because I grepped for ".log" instead of "log" when looking for code
snippets to change in any `*sh` file. Like this one above
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
