Hi Aitozi, Flink will check upon job start and fail if - max parallelism > parallelism (KeyGroupRangeAssignment.computeKeyGroupRangeForOperatorIndex) or - max parallelism of savepoint > max parallelism of restored job (Checkpoints.loadAndValidateCheckpoint).
Theoretically that would be possible without migration and state loss but with wasting increased resources which does not make sense. Best, Andrey On Thu, Feb 14, 2019 at 3:50 AM aitozi <gjying1...@gmail.com> wrote: > Hi, Andrey > > I have another question that if i do not set the maximum parallelism > first(which be set to 128 by default), and then rescale to a parallelism > bigger than 128. In this scenario，will the state lost? > > Thanks, > Aitozi > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
