:
> 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,
>>
>> W
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
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
