Re: Restoring state from an incremental RocksDB checkpoint

2020-03-13 Thread Andrey Zagrebin
As I understand you have already enabled retained checkpoints [1] because you can only restore from them in case of job cancellation to restart it. Just in case, here is also the link to docs about restoring from a retained checkpoint [2] and how to find path to it [3]. [1] https://ci.apache.or

Re: Restoring state from an incremental RocksDB checkpoint

2020-03-13 Thread Andrey Zagrebin
Hi Yuval, You should be able to restore from the last checkpoint by restarting the job with the same checkpoint directory. An incremental part is removed only if none of retained checkpoints points to it. Best, Andrey > On 13 Mar 2020, at 16:06, Yuval Itzchakov wrote: > > Hi, > > We're usin

Restoring state from an incremental RocksDB checkpoint

2020-03-13 Thread Yuval Itzchakov
Hi, We're using RocksDB as a state backend. We've come to a situation where due to high backpressure in one of our operators, we can't make a savepoint complete. Since we have retained previous checkpoints, I was wondering if these would be eligible to serve as a restoration point, given that we