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 <myas...@live.com> wrote: > 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 > ------------------------------ > *From:* Rex Fenley <r...@remind101.com> > *Sent:* Tuesday, January 12, 2021 11:01 > *To:* user <user@flink.apache.org> > *Cc:* Brad Davis <brad.da...@remind101.com> > *Subject:* Restoring from checkpoint with different parallism > > Hello, > > When using the TableAPI, is it safe to run a flink job with a different > `-p` parallelism while restoring from a checkpoint (not a savepoint) using > `-s`, without any rescaling of actual machines? I don't seem to find this > documented anywhere. > > Thanks! > > -- > > Rex Fenley | Software Engineer - Mobile and Backend > > > Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | > FOLLOW US <https://twitter.com/remindhq> | LIKE US > <https://www.facebook.com/remindhq> > -- Rex Fenley | Software Engineer - Mobile and Backend Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | FOLLOW US <https://twitter.com/remindhq> | LIKE US <https://www.facebook.com/remindhq>
