Flink 1.2 startet nicht im HA-Cluster-Modus

Question

Ich habe Flink 1.2 im HA-Cluster-Modus 2 JobManagers 1 TaskManager lokal installiert und es weigerte sich immer noch, in diesem Modus zu starten und "Startcluster" zu zeigen. Nachricht anstelle von "Starten von HA-Cluster mit 2 Mastern und 1 Peers im ZooKeeper-Quorum."

Offenbar in der ist/config.sh es liest die Konfiguration wie:

# High availability 
if [ -z "${HIGH_AVAILABILITY}" ]; then 
    HIGH_AVAILABILITY=$(readFromConfig ${KEY_HIGH_AVAILABILITY} "" "${YAML_CONF}") 
    if [ -z "${HIGH_AVAILABILITY}" ]; then 
     # Try deprecated value 
     DEPRECATED_HA=$(readFromConfig "recovery.mode" "" "${YAML_CONF}") 
     if [ -z "${DEPRECATED_HA}" ]; then 
      HIGH_AVAILABILITY="none" 
     elif [ ${DEPRECATED_HA} == "standalone" ]; then 
      # Standalone is now 'none' 
      HIGH_AVAILABILITY="none" 
     else 
      HIGH_AVAILABILITY=${DEPRECATED_HA} 
     fi 
    else 
     HIGH_AVAILABILITY="none" 
    fi 
fi 

was bedeutet, unabhängig von dem, was für „Hochverfügbarkeit“ Schlüssel in der Konfigurationsdatei (in meinem Fall Wert konfiguriert ist, war " Zoowärter ") wird es diese Option setzen "none" und in ist/start-cluster.sh

if [[ $HIGH_AVAILABILITY == "zookeeper" ]]; then 
    # HA Mode 
    readMasters 

    echo "Starting HA cluster with ${#MASTERS[@]} masters." 

    for ((i=0;i<${#MASTERS[@]};++i)); do 
     master=${MASTERS[i]} 
     webuiport=${WEBUIPORTS[i]} 
     ssh -n $FLINK_SSH_OPTS $master -- "nohup /bin/bash -l \"${FLINK_BIN_DIR}/jobmanager.sh\" start cluster ${master} ${webuiport} &" 
    done 

else 
    echo "Starting cluster." 

    # Start single JobManager on this machine 
    "$FLINK_BIN_DIR"/jobmanager.sh start cluster 
fi 

werden nie in dem ersten, wenn Zweig erhalten.

Hat jemand anderes das gesehen?

Answer 1

Ja, ich glaube, es ist ein Fehler: issues.apache.org/jira/browse/FLINK-6000.

Es hat bereits eine ausstehende PR.