[GitHub] flink pull request #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMa...

[fhueske <gi...@git.apache.org>]

Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5750#discussion_r176727554
  
    --- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
    @@ -59,6 +146,57 @@ function start_cluster {
       done
     }
     
    +function jm_watchdog() {
    +    expectedJms=$1
    +    ipPort=$2
    +
    +    while true; do
    +        runningJms=`jps | grep -o 'StandaloneSessionClusterEntrypoint' | wc -l`;
    +        missingJms=$((expectedJms-runningJms))
    +        for (( c=0; c<missingJms; c++ )); do
    +            "$FLINK_DIR"/bin/jobmanager.sh start "localhost" $2
    +        done
    +        sleep 5;
    +    done
    +}
    +
    +function kill_jm {
    +    idx=$1
    +
    +    jm_pids=`jps | grep 'StandaloneSessionClusterEntrypoint' | cut -d " " -f 1`
    +    jm_pids=(${jm_pids[@]})
    +
    +    pid=${jm_pids[$idx]}
    +
    +    # kill the JM and wait for the completion of its termination
    +    kill -9 ${pid}
    +
    +    echo "Killed JM @ ${pid}."
    +}
    +
    +function stop_ha_cluster {
    +    echo "Tearing down HA Cluster..."
    +    stop_cluster
    +    stop_local_zk
    +    cleanup
    +}
    +
    +function stop_local_zk {
    +    while read server ; do
    +        server=$(echo -e "${server}" | sed -e 's/^[[:space:]]*//' -e 's/[[:space:]]*$//') # trim
    +
    +        # match server.id=address[:port[:port]]
    +        if [[ $server =~ ^server\.([0-9]+)[[:space:]]*\=[[:space:]]*([^: \#]+) ]]; then
    +            id=${BASH_REMATCH[1]}
    --- End diff --
    
    `id` doesn't seem to be used
    `server` doesn't seem to be used (or is it overriding the outer `server` variable`?)


---