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 > > >
