Flink 1.2不以HA群集模式开始



我已经在ha群集模式下安装了flink 1.2 jobmanagers 1 taskmanager在本地,它一直拒绝在此模式下实际启动"开始群集。"消息而不是"在Zookeeper Quorum中以2个大师和1个同行开始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"),它将将其设置为"无"和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

如果分支,永远不会进入第一个。

其他人面对这个?

是的,我相信这是一个错误:

它已经有一个未决的pr。

相关内容

  • 没有找到相关文章

最新更新