self-define the window assigners. Caizhi Weng <tsreape...@gmail.com> 于2022年1月17日周一 13:11写道：
> Hi! > > So you'd like to flatten the traffic by materializing the results of > different parallelisms at different times? > > As far as I know this is not possible. Could you please elaborate more on > the reason you'd like to flatten the traffic? Is it causing any problems > with your job? What's your use case for streaming windows? > > Also the only type of window capable of emitting results for different > parallelisms at different times is the session window [1]. Does that meet > your needs? > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/windows/#session-windows > > Aeden Jameson <aeden.jame...@gmail.com> 于2022年1月15日周六 02:16写道： > >> When using tumbling windows the windows materialize all at once which >> results in burst-y traffic. How does one go about unaligned tumbling >> windows? Does this require going down the road of custom window, assigner >> and triggers? >> >> -- >> Cheers, >> Aeden >> >> >>
