Re: jobmanager rpc inside kubernetes

2018-04-26 Thread Sampath Bhat
It would be helpful if you provide the complete CLI logs. Because even I'm using flink run command to submit jobs to flink jobmanager running on K8s and its working fine. For remote execution using flink CLI you should provide flink-conf.yaml file which contains job manager address, port and SSL/HA

jobmanager rpc inside kubernetes

2018-04-26 Thread Chris Latko
when trying to submit a job to my k8s cluster using `flink run -m localhost:6123 app.jar` i get the following error in jobmanager log: - dropping message [class akka.actor.ActorSelectionMessage] for non-local recipient [Actor[akka.tcp://flink@localhost:6123/]] arriving at [akka.tcp://flink@loc