nk you so much!
> Jiahui
> --
> *From:* Yun Tang
> *Sent:* Tuesday, June 15, 2021 10:27 PM
> *To:* Guowei Ma ; Jiahui Jiang <
> qzhzm173...@hotmail.com>
> *Cc:* user@flink.apache.org
> *Subject:* Re: Discard checkpoint files through a single recursive call
>
&g
From: Yun Tang
Sent: Tuesday, June 15, 2021 10:27 PM
To: Guowei Ma ; Jiahui Jiang
Cc: user@flink.apache.org
Subject: Re: Discard checkpoint files through a single recursive call
Hi Jiang,
Please take a look at FLINK-17860 and FLINK-13856 for previous discussion of
this problem.
[1] https
, June 16, 2021 8:40
To: Jiahui Jiang
Cc: user@flink.apache.org
Subject: Re: Discard checkpoint files through a single recursive call
hi, Jiang
I am afraid of misunderstanding what you mean, so can you elaborate on how you
want to change it? For example, which interface or class do you want to add a
hi, Jiang
I am afraid of misunderstanding what you mean, so can you elaborate on how
you want to change it? For example, which interface or class do you want to
add a method to?
Although I am not a state expert, as far as I know, due to incremental
checkpoints, when CompleteCheckpoint is discardin
