Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175812472
--- 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
--- End diff --
Would be good to make it work with the legacy code as well.
---
