:
> If the checkpoint timeout leads to the job's fail, then the job will be
> recovered and data will be reprocessed from the last completed checkpoint.
> If the job doesn't fail, then not.
>
> Mahantesh Patil 于2022年3月8日周二 14:47写道：
>
>> Hello Team,
>>
Hello Team,
What happens after checkpoint timeout?
Does Flink reprocess data from the previous checkpoint for all tasks?
I have one compute intensive operator with parallelism of 20 and only one
of the parallel tasks seems to get stuck because of data skew. On
checkpoint timeout , will data be r
Hi Team,
Following up to check if any of you have faced this issue. If so how to
resolve this.
Regards,
Mahantesh Patil.
On Mon, Feb 11, 2019 at 3:50 PM Mahantesh Patil
wrote:
> Hi Team,
>
> We have Flink jobs running in cluster mode. When I cancel the job and
> check for sta
:07,182 INFO org.apache.flink.runtime.taskmanager.Task -
Attempting to cancel task filter-business-metrics -> Sink: data_feed (1/1)
(6c229624ea4735215fe98f5458c58c8e).
10 Jan 2019 20:37:07,182 INFO org.apache.flink.runtime.taskmanager.Task -
Task filter-business-metrics -> Sink: data_feed (1/1) is already in state
CANCELING
