FLINK 1.2は、私はローカルHAクラスタモードで2 JobManagers 1タスクマネージャをFLINK 1.2をインストールしているし、それが実際に を示す。このモードで起動することを拒否ままHAクラスタモード

Question

で起動しない「クラスタを起動します。」 の代わりに "ZooKeeperクォーラムに2つのマスターと1つのピアを持つHAクラスタを開始しています。" （私の場合には値が "だった独立した構成ファイル内の「高可用性」キー用に設定されているものの意味

# 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 

：

はどうやらbinに/ config.shと、それは次のように構成を読み取りzookeeper "）それは" none "とbin/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 

は最初のブランチに入ることはありません。

他にも誰かがこれに直面しましたか？ issues.apache.org/jira/browse/FLINK-6000：

Answer 1

はい、私はそれがバグであると信じています。

すでにPRが保留中です。