任务管理器无法连接到工作经理



我正在尝试将弗林克集群从1.4.2升级到1.7.2

当我提出集群时,任务经理拒绝使用以下错误连接到工作经理。

2019-03-14 10:34:41,551 WARN  akka.remote.ReliableDeliverySupervisor                        
- Association with remote system [akka.tcp://flink@cluster:22671] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@cluster:22671]] Caused by: [cluster: Name or service not known]

现在,如果我将以下行添加到/etc/hosts文件中,则可以正常工作。

x.x.x.x job-manager-address.com cluster

为什么Flink 1.7.2在地址中使用cluster连接到JM?Flink 1.4.2曾经具有工作经理的地址,而不是 cluster

jobmanager.sh脚本正在用第二个称为 cluster的参数调用。

${Flink_HOME}/bin/jobmanager.sh start cluster

在1.5之前,脚本期望执行模式(本地或群集),但事实并非如此。在没有第二个参数的情况下调用脚本解决了这个问题。

${Flink_HOME}/bin/jobmanager.sh start

  • http://apache-flink-user-mailing-list-archive.2336050.n4.n4.nabble.com/flink-1-7-2-task-manager-not-not-able-to-to-connect-to-connect-to-connect-to-job-manager-td26707.html
  • https://github.com/apache/flink/commit/d61664ca64bcb82c4e8ddf03a2a2ed38fe8fe8fe8fe8deafa98
  • https://github.com/apache/flink/blob/c6878aaca6c5aeee46581b4d67444b31049db955/flink-dist/src/src/src/main/main/main/flink-bin/bin/bin/bin/jobmanager.sh/jobmanager.shubmanager.sh#ul21-l21-l21-l25

相关内容

  • 没有找到相关文章

最新更新