So I guess it had some older state? On Thu., Oct. 3, 2019, 11:29 a.m. John Smith, <java.dev....@gmail.com> wrote:
> I'm running standalone cluster with Zookeeper. It seems it was trying to > connect to an older node. I rebooted the Job node tha was complaining. It > seems to be ok now... > > I have 3 Zookeepers, 3 Job Nodes and 3 Tasks Nodes > > On Thu, 3 Oct 2019 at 11:15, Zili Chen <wander4...@gmail.com> wrote: > >> Hi John, >> >> could you provide some details such as which mode you runs >> on(standalone/YARN) >> and related configuration(jobmanager.address jobmanager.port and so on)? >> >> Best, >> tison. >> >> >> John Smith <java.dev....@gmail.com> 于2019年10月3日周四 下午11:02写道: >> >>> Hi running 1.8 the cluster seems to be OK but I see these warnings in >>> the logs... >>> >>> 2019-10-03 14:57:25,152 WARN akka.remote.transport.netty.NettyTransport >>> - Remote connection to [null] failed with >>> java.net.ConnectException: Connection refused: /xxx.xxx.xxx.65:46167 >>> 2019-10-03 14:57:25,156 WARN akka.remote.ReliableDeliverySupervisor >>> - Association with remote system >>> [akka.tcp://fl...@xxx.xxx.xxx.65:46167] has failed, address is now >>> gated for [50] ms. Reason: [Association failed with >>> [akka.tcp://fl...@xxx.xxx.xxx.65:46167]] Caused by: [Connection >>> refused: /xxx.xxx.xxx.65:46167] >>> >>> >>>