Hey guys and gals,
So, after a bit more digging, I found out that once HA is enabled, `jobmanager.rpc.port` is also ignore (along with `jobmanager.rpc.address`, but I was expecting this). Because I set the `high-availability.jobmanager.port` to `50010-50015`, my RPC port also changed (the docs made me think this would only affect the HA communication, not ALL communications). This can be checked on the Dashboard, under the JobManager configuration option.
But that didn't solve my problem. So far, the `flink run` still fails with the same message (I'm adding the full stacktrace of the failure in the end, just in case), but now I'm also seeing this message in the JobManager logs:
2018-05-02 16:44:32,373 WARN org.apache.flink.runtime.jobmanager.JobManager - Discard message LeaderSessionMessage(00000000-0000-0000-0000-000000000000,SubmitJob(JobGraph(jobId: 42a25752ab085117a21c02d3db54777e),DETACHED)) because the expected leader session ID c01eba4f-44e2-4c65-85d5-a9a05ceba28e did not equal the received leader session ID 00000000-0000-0000-0000-000000000000.
So, I'm still lost on where to go forward.