Flink 1.2無法在HA羣集模式下啓動

我已在本地HA集羣模式2 JobManager 1 TaskManager中安裝Flink 1.2，並且它始終拒絕以此模式啓動，顯示「正在啓動羣集」。消息而不是「在ZooKeeper仲裁中啓動2個主節點和1個對等節點的HA羣集。」Flink 1.2無法在HA羣集模式下啓動

顯然在bin/config.sh它讀起來就像配置：

# 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

這意味着獨立的什麼配置爲配置文件中的「高可用性」鍵（在我的情況下，值「 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

永遠不會進入第一個if分支。

其他人面臨這個？

來源

2017-03-14 razvan

是的我相信這是一個錯誤：https://issues.apache.org/jira/browse/FLINK-6000 –

嗨，真的，如果你回答這個問題，我可以把它標記爲回答 – razvan

是的我相信這是一個bug：issues.apache.org/jira/browse/FLINK-6000。

它已經有一個未決的PR。

來源

2017-03-15 09:42:32

Flink 1.2無法在HA羣集模式下啓動

回答

相關問題