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
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