我正在尝试将弗林克集群从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