Akka wants to connect with username "flink"

Posted by Lukas Werner on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Akka-wants-to-connect-with-username-flink-tp18676.html

Hey there,

For my master thesis I'm trying to set up a flink standalone cluster on 4 nodes. I've worked along the documentation which pretty neatly explains how to set it up. But when I start the cluster there is a warning and when I'm trying to run a job, there is an error with the same message:

akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@MYHOSTNAME:6123/user/jobmanager#-818199108]] after [10000 ms]. Sender[null] sent message of type "org.apache.flink.runtime.messages.JobManagerMessages$LeaderSessionMessage"

Increasing the timeout didn't work. When I open the taskmanagers in web UI, all of them have the following pattern:

akka.tcp://flink@MYHOSTNAME:33779/user/taskmanager

Does anyone have an idea how to solve this to get the cluster working? Thanks in advance!

One last thing: There isn't a user "flink" on the cluster and won't be created. So any advices without telling me I should create that user would be very appreciated! Thanks!

Kind regards,
Lukas