Re: Restoring from checkpoint with different parallism

2021-01-15 Thread Arvid Heise
Hi Rex, that's exactly right and we are also working on bringing this feature to unaligned checkpoints. On Tue, Jan 12, 2021 at 5:18 AM Rex Fenley wrote: > Thanks! Looks like you can't with unaligned checkpoints, which seems to > imply that you can with normal checkpointing mechanism. > > On Mo

Re: Restoring from checkpoint with different parallism

2021-01-11 Thread Rex Fenley
Thanks! Looks like you can't with unaligned checkpoints, which seems to imply that you can with normal checkpointing mechanism. On Mon, Jan 11, 2021 at 7:56 PM Yun Tang wrote: > Hi Rex, > > I think doc [1] should have given some descriptions. Rescaling from > previous checkpoint is still suppor

Re: Restoring from checkpoint with different parallism

2021-01-11 Thread Yun Tang
Hi Rex, I think doc [1] should have given some descriptions. Rescaling from previous checkpoint is still supported in current Flink version. [1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html#resuming-from-a-retained-checkpoint Best Yun Tang