[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258912#comment-15258912 ]
Konstantin Knauf commented on FLINK-3669: ----------------------------------------- [~aljoscha] Hmpf. You're right. I was actually a little bit suspicious, that I did not need any additional state ;) Anyway, I pushed a new version. This time also with modifications to StreamTask to set deleteOnCancelPolicy(true). https://github.com/knaufk/flink/tree/FLINK-3669 Aside: A lot of my Travis-Builds fail with a compilation problem in flink-connector-elasticsearch2 even on master (e.g. https://travis-ci.org/knaufk/flink/builds/125920011 3 und 5). What's the reason? > 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 > Assignee: Konstantin Knauf > 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)