[
https://issues.apache.org/jira/browse/FLINK-12855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Teng Hu updated FLINK-12855:
----------------------------
Attachment: (was: stagger_window_delay.png)
> Stagger panes on partitions to distribute workload.
> ---------------------------------------------------
>
> Key: FLINK-12855
> URL: https://issues.apache.org/jira/browse/FLINK-12855
> Project: Flink
> Issue Type: New Feature
> Components: API / DataStream
> Reporter: Teng Hu
> Priority: Major
> Attachments: stagger_window.png, stagger_window_delay.png,
> stagger_window_throughput.png
>
>
> Flink natively triggers all panes belonging to same window at the same time.
> In other words, all panes are aligned and their triggers all fire
> simultaneously, causing the thundering herd effect.
> This new feature provides the option that panes could be staggered across
> partitioned streams, so that their workloads are distributed.
> Attachment: proof of concept working
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
