You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Will Walters <ww...@yahoo-inc.com> on 2017/06/20 23:44:15 UTC

Session ID Error

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.

Re: Session ID Error

Posted by Aljoscha Krettek <al...@apache.org>.

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 <ww...@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.