Hi Puneet,
if context.isRestored returns false, then Flink did not resume from a
checkpoint/savepoint. Please make sure that you specify the correct path
the an existing checkpoint.
Cheers,
Till
On Mon, Jan 7, 2019 at 11:04 AM Puneet Kinra <
puneet.ki...@customercentria.com> wrote:
> Hi Till
>
Hi Till
Its Working for me know ,but *context.isRestored() **is always returning
false.*
On Fri, Jan 4, 2019 at 7:42 PM Till Rohrmann wrote:
> When starting a job from within the IDE using the LocalEnvironment, it is
> not possible to specify a checkpoint from which to resume. That's why your
>
When starting a job from within the IDE using the LocalEnvironment, it is
not possible to specify a checkpoint from which to resume. That's why your
recovered state is empty. Flink won't automatically pick up the latest
checkpoint it finds in some checkpoint directory.
You can test it though by st
The List it returns is blank
On Fri, Jan 4, 2019 at 7:15 PM Till Rohrmann wrote:
> Hi Puneet,
>
> what exactly is the problem when you try to resume from a checkpoint?
>
> Cheers,
> Till
>
> On Fri, Jan 4, 2019 at 2:31 PM Puneet Kinra <
> puneet.ki...@customercentria.com> wrote:
>
>> Hi All
>>
>
Hi Puneet,
what exactly is the problem when you try to resume from a checkpoint?
Cheers,
Till
On Fri, Jan 4, 2019 at 2:31 PM Puneet Kinra <
puneet.ki...@customercentria.com> wrote:
> Hi All
>
> I am creating a poc where i am trying the out of box feature of flink
> for managed state of operator
Hi All
I am creating a poc where i am trying the out of box feature of flink
for managed state of operator . I am able to create the checkpoint while
running my app in eclipse but when i am trying to restart the app . I am
unable to restore
the state.
Please find attached below snippet.
step fol
