Hi Yang, Flink keeps the max key groups the same no matter how parallelism changes, and use this to avoid state data lost [1]
[1] https://flink.apache.org/features/2017/07/04/flink-rescalable-state.html Best Yun Tang On 2021/11/26 10:07:29 Nicolaus Weidner wrote: > Hi, > > to rescale, you should take a savepoint, stop the job, then restart from > the savepoint with your new desired parallelism. This way, no data will be > lost. > > Best, > Nico > > On Thu, Nov 25, 2021 at 10:53 AM 杨浩 <yangha...@163.com> wrote: > > > Will Flink loss some old Keyed State when changing the parallelism, like 2 > > -> 5, or 5->3? > > > > > > > > > > > > > > >
