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.
