On Thu, Jan 20, 2022 at 2:46 AM yidan zhao wrote:
> self-define the window assigners.
>
Thanks, I'll check that out. If you have links to especially good examples
and explanations, that would be great. Otherwise, I presume the Flink
codebase itself is the place to start.
--
Cheers,
Aeden
Hi Caizhi,
Thanks for responding.
>So you'd like to flatten the traffic by materializing the results of
different parallelisms at different times?
Yes.
> What's your use case for streaming windows?
In short, summarizing many-many-many millions of sessions every minute
involving mostly stateless,
self-define the window assigners.
Caizhi Weng 于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 t
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 cas
