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