Hi Huang, this seems to be very strange, because the JobManager’s actor system has bound to the address 9-96-101-177 instead of 9.96.101.177. It seems a if the . have been replaced by -.
Could you maybe tell me which version of Flink you’re running and also share the complete JobManager log with us? I tested it with the latest 1.2 SNAPSHOT version and there it seemed to work. Cheers, Till On Fri, Jan 13, 2017 at 9:02 AM, huangwei (G) <huangwei...@huawei.com> wrote: > Dear All, > > I get an error in jobmanage.log following when I submit a flink job > (batch/WordCount.jar) by using command : "./bin/flink run -m > 9.96.101.177:39180 ./examples/batch/WordCount.jar". > > And the flink is on yarn cluster. > > Error in jobmanage.log : > 2017-01-13 15:28:27,402 ERROR akka.remote.EndpointWriter > - dropping message [class akka.actor.ActorSelectionMessage] > for non-local recipient [Actor[akka.tcp://flink@9.96.101.177:39180/]] > arriving at [akka.tcp://flink@9.96.101.177:39180] inbound addresses are > [akka.tcp://flink@9-96-101-177:39180] > > However, It is success when I use flink web-ui to submit the job. > > How to solve this problem? > > And otherwise, when I started the flink on yarn, the jobmanage.rpc.port > and the web port both were changed to 39180 and 57724. > The configuration following in flink-conf.yaml is just as default : > > jobmanager.rpc.port: 6123 > > and > > jobmanager.web.port: 8081 > > I started the flink on yarn using command : "./bin/yarn-session.sh -n 4". > > Why were the ports changed to 39180 and 57724? > > Many thanks if there is any help! > > HuangWHWHW > 2017.1.13 >
