Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r175812511 --- Diff: flink-end-to-end-tests/test-scripts/common.sh --- @@ -176,10 +176,40 @@ function s3_delete { https://${bucket}.s3.amazonaws.com/${s3_file} } +function tm_watchdog { + expectedTm=$1 + while true; + do + runningTm=`jps | grep -o 'TaskManagerRunner' | wc -l`; + count=$((expectedTm-runningTm)) + for (( c=0; c<count; c++ )) + do + $FLINK_DIR/bin/taskmanager.sh start > /dev/null + done + sleep 5; + done +} + +function jm_kill_all { + kill_all StandaloneSessionClusterEntrypoint +} + +function tm_kill_all { + kill_all TaskManagerRunner --- End diff -- Same here
---