flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrey Zagrebin <and...@ververica.com>
Subject Re: Production readiness
Date Fri, 15 Feb 2019 10:27:29 GMT
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 <gjying1314@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/
>

Mime
View raw message