Flink 1.2가 HA 클러스터 모드에서 시작하지 않습니다.

Question

Flink 1.2를 HA 클러스터 모드 2 JobManagers 1 TaskManager에 로컬로 설치했으며 실제로이 모드에서 시작하기를 거부했습니다. "Starting cluster." 대신 "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 

("이었다 : 분명히 빈에서

은/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 

분기가없는 경우 첫 번째 분기에는 절대 들어 가지 않습니다.

다른 사람이이 문제에 직면 했습니까?

Answer 1

예 버그라고 생각합니다. issues.apache.org/jira/browse/FLINK-6000.

이미 보류중인 PR이 있습니다.