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群集模式下启动

回答

相关问题