[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230891#comment-15230891
]
Konstantin Knauf commented on FLINK-3669:
-----------------------------------------
I have a first draft here: https://github.com/knaufk/flink/tree/FLINK-3669
I decided to go for timer coalescing. Basically I am using a {{MultiSet}} for
the Timers instead of the {{Set}} now, to keep track of the count of equivalent
Timers. I am happy about comments. Surely there are test missing.
On thing we could think about is making the granularity of the coalescing
configurable, i.e. coalescing all timer wihtin in 10ms or so, but this is
pretty optional I think.
> WindowOperator registers a lot of timers at StreamTask
> ------------------------------------------------------
>
> Key: FLINK-3669
> URL: https://issues.apache.org/jira/browse/FLINK-3669
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 1.0.1
> Reporter: Aljoscha Krettek
> Priority: Blocker
>
> Right now, the WindowOperator registers a timer at the StreamTask for every
> processing-time timer that a Trigger registers. We should combine several
> registered trigger timers to only register one low-level timer (timer
> coalescing).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
