Hi Will, How did you configure Flink and what is the command that you’re using to submit your job/session?
Best, Aljoscha > On 21. Jun 2017, at 01:44, Will Walters <wwalt...@yahoo-inc.com> wrote: > > Hello, > > In attempting to submit a job via Yarn session on Hadoop cluster (using Flink > 1.2.1), I get timed out and receive the following error from the server: > > Discard message > LeaderSessionMessage(00000000-0000-0000-0000-000000000000,SubmitJob(JobGraph(jobId: > 5d0406fc547af4fc36bf78ed812a3f90),EXECUTION_RESULT_AND_STATE_CHANGES)) > because the expected leader session ID None did not equal the received leader > session ID Some(00000000-0000-0000-0000-000000000000). > This seems to be an issue with the way that a Null session ID is handled. Is > there a way to manually set the session ID? Any advice would be greatly > appreciated. > > Thank you, > Will Walters.
