flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "huangwei (G)" <huangwei...@huawei.com>
Subject some questions about submit flink job on flink-yarn
Date Fri, 13 Jan 2017 08:02:59 GMT
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 ./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@]]
arriving at [akka.tcp://flink@] 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


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!

View raw message