You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Steven Wu <st...@gmail.com> on 2020/07/06 03:08:03 UTC

Does savepoint reset the base for incremental checkpoint

In this sequence of (checkpoint x, savepoint y, checkpoint x+1), does
checkpoint x+1 build the incremental diff based on checkpoint x or
savepoint y?

Thanks,
Steven

Re: Does savepoint reset the base for incremental checkpoint

Posted by Congxian Qiu <qc...@gmail.com>.

Hi

checkpoint base is only used in the incremental checkpoint, the answer for
the first question is checkpoint x.

After restoring from a savepoint, there is no base for the first checkpoint.

you can ref to the code[1][2] for more information.

[1]
https://github.com/apache/flink/blob/c14f9d2f9f6d6f2da3dc41fcef010e12405e25eb/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java#L416
[2]
https://github.com/apache/flink/blob/master/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBFullRestoreOperation.java

Best,
Congxian


Steven Wu <st...@gmail.com> 于2020年7月6日周一 上午11:46写道：

> In a slightly different variation of sequence (checkpoint x, savepoint y,
> redeploy/restart job from savepoint y, checkpoint x+1), checkpoint x+1
> builds the incremental diff on savepoint y, right?
>
> On Sun, Jul 5, 2020 at 8:08 PM Steven Wu <st...@gmail.com> wrote:
>
>>
>> In this sequence of (checkpoint x, savepoint y, checkpoint x+1), does
>> checkpoint x+1 build the incremental diff based on checkpoint x or
>> savepoint y?
>>
>> Thanks,
>> Steven
>>
>

Re: Does savepoint reset the base for incremental checkpoint

Posted by Steven Wu <st...@gmail.com>.

In a slightly different variation of sequence (checkpoint x, savepoint y,
redeploy/restart job from savepoint y, checkpoint x+1), checkpoint x+1
builds the incremental diff on savepoint y, right?

On Sun, Jul 5, 2020 at 8:08 PM Steven Wu <st...@gmail.com> wrote:

>
> In this sequence of (checkpoint x, savepoint y, checkpoint x+1), does
> checkpoint x+1 build the incremental diff based on checkpoint x or
> savepoint y?
>
> Thanks,
> Steven
>