this seems to be very strange, because the JobManager’s actor system has
bound to the address 9-96-101-177 instead of 18.104.22.168. 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
On Fri, Jan 13, 2017 at 9:02 AM, huangwei (G) <huangwei...@huawei.com>
> 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
> 22.214.171.124: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://firstname.lastname@example.org:39180/]]
> arriving at [akka.tcp://email@example.com:39180] inbound addresses are
> 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
> 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!