Re: Flink job server with HA

2019-06-04 Thread Boris Lublinsky
Please refer to >>> MiniDispatcher and SingleJobSubmittedJobGraphStore for the details. >>> >>> I think we need more information to find the root cause of your problem. >>> For example, can you explain what are the detailed operation steps do you >>> perform when y

Re: Flink job server with HA

2019-06-03 Thread Xintong Song
>> MiniDispatcher and SingleJobSubmittedJobGraphStore for the details. >> >> I think we need more information to find the root cause of your problem. >> For example, can you explain what are the detailed operation steps do you >> perform when you say "trying to r

Re: Flink job server with HA

2019-06-03 Thread Boris Lublinsky
you say "trying to restart a Job Master". >> >> Thank you~ >> Xintong Song >> >> >> On Mon, Jun 3, 2019 at 10:05 PM Boris Lublinsky >> mailto:boris.lublin...@lightbend.com>> wrote: >> I am trying to experiment with Flink Job server with HA a

Re: Flink job server with HA

2019-06-03 Thread Xintong Song
ur problem. > For example, can you explain what are the detailed operation steps do you > perform when you say "trying to restart a Job Master". > > Thank you~ > Xintong Song > > > > On Mon, Jun 3, 2019 at 10:05 PM Boris Lublinsky < > boris.lublin...@lightbe

Re: Flink job server with HA

2019-06-03 Thread Boris Lublinsky
ou explain what are the detailed operation steps do you perform > when you say "trying to restart a Job Master". > > Thank you~ > Xintong Song > > > On Mon, Jun 3, 2019 at 10:05 PM Boris Lublinsky > mailto:boris.lublin...@lightbend.com>> wrote: > I am

Re: Flink job server with HA

2019-06-03 Thread Xintong Song
, can you explain what are the detailed operation steps do you perform when you say "trying to restart a Job Master". Thank you~ Xintong Song On Mon, Jun 3, 2019 at 10:05 PM Boris Lublinsky < boris.lublin...@lightbend.com> wrote: > I am trying to experiment with Flink Job s

Flink job server with HA

2019-06-03 Thread Boris Lublinsky
I am trying to experiment with Flink Job server with HA and I am noticing, that in this case method putJobGraph in the class SubmittedJobGraphStore Is never invoked. (I can see that it is invoked in the case of session cluster when a job is added) As a result, when I am trying to restart a Job