回复:Re: Will Flink loss some old Keyed State when changing the parallelism

top 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 杨浩 wrote: >> >> > Will Flink loss some old Keyed State when changing the parallelism, like 2 >> > -> 5, or 5->3? >> > >> > >> > >> > >> > >> > >> > >>

Will Flink loss some old Keyed State when changing the parallelism

Will Flink loss some old Keyed State when changing the parallelism, like 2 -> 5, or 5->3?

offset of TumblingEventTimeWindows

As in China (UTC+08:00)，we should use Time.hours(-8) as offset when state day's data, // daily tumbling event-time windows offset by -8 hours. input.keyBy().window(TumblingEventTimeWindows.of(Time.days(1),Time.hours(-8))).() shall we also set Time.hours(-8) as offset for minute's state ?

how to view doc of flink-1.10 in Chinese

Our company use release-1.10，can we see the zh doc? English Doc：https://ci.apache.org/projects/flink/flink-docs-release-1.10/ Chinese Doc(only view latest)：https://flink.apache.org/zh/flink-architecture.html