intCoordinator[] - No master
state to restore
2
Thanks,
Ifat
From: yidan zhao
Date: Wednesday, 2 March 2022 at 4:08
To: "Afek, Ifat (Nokia - IL/Kfar Sava)"
Cc: zhlonghong , "user@flink.apache.org"
Subject: Re: Flink job recovery after task manager failure
State
system be
shared between the task managers and job managers? Is there another option?
Thanks,
Ifat
From: Zhilong Hong
Date: Thursday, 24 February 2022 at 19:58
To: "Afek, Ifat (Nokia - IL/Kfar Sava)"
Cc: "user@flink.apache.org"
Subject: Re: Flink job recovery after task
Hi Zhilong,
I will check the issues you raised.
Thanks for your help,
Ifat
From: Zhilong Hong
Date: Thursday, 24 February 2022 at 19:58
To: "Afek, Ifat (Nokia - IL/Kfar Sava)"
Cc: "user@flink.apache.org"
Subject: Re: Flink job recovery after task manager failure
Hi, Afe
<https://nokia-my.sharepoint.com/:u:/p/ifat_afek/EUsu4rb_-BpNrkpvSwzI-vgBtBO9OQlIm0CHtW0gsZ7Gqg?email=zhlonghong%40gmail.com&e=ww5Idt>
Thanks,
Ifat
From: Zhilong Hong
Date: Wednesday, 23 February 2022 at 19:38
To: "Afek, Ifat (Nokia - IL/Kfar Sava)"
Cc: "user@flink.apache
Hi,
I am trying to use Flink checkpoints solution in order to support task manager
recovery.
I’m running flink using beam with filesystem storage and the following
parameters:
checkpointingInterval=3
checkpointingMode=EXACTLY_ONCE.
What I see is that if I kill a task manager pod, it takes f
