time
semantics.
For processing idle partition scenarios, currently, Flink allows
calling markAsTemporarilyIdle to send StreamStatus.IDLE to the downstream.
Best,
Vino
Shu Su 于2019年6月24日周一 下午9:13写道：
Hi vino
Thanks for proposal.
For Local Aggregation I have a question about doing this in window
Hi vino
Thanks for proposal.
For Local Aggregation I have a question about doing this in window aggregation.
As we know , window aggregation like sliding window should based on
Time trigger, and there may exists a problem in event time if we do local
aggregation. For example if I want to do a
