flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl0u <...@git.apache.org>
Subject [GitHub] flink pull request #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMa...
Date Tue, 27 Mar 2018 14:04:51 GMT
Github user kl0u commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5750#discussion_r177436350
  
    --- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
    @@ -59,9 +162,42 @@ 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" ${ipPort}
    --- End diff --
    
    Actually we launch only one, and we kill it and then start a new one.


---

Mime
View raw message