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://[email protected]:39180/]] arriving at
[akka.tcp://[email protected]: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
