[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

[tillrohrmann]

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


---