[
https://issues.apache.org/jira/browse/STORM-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193155#comment-15193155
]
ASF GitHub Bot commented on STORM-676:
--------------------------------------
Github user arunmahadevan commented on the pull request:
https://github.com/apache/storm/pull/1072#issuecomment-196279990
Haven't gone through the code in great detail, but when I ran a simple
topology with a tumbling time window of 3 secs,
- If the spout emits a batch and sleeps, the result of the window
agregation is never emitted (ideally it should have emitted at 3 secs).
- If the spout periodically emits batches (one batch every 5 sec), the time
when the window output is generated always conincides with the time the spout
emits the batches (i.e at 10, 15, 20 secs) whereas one would expect the result
to be emitted at 6, 12, 15, 18 etc. Also only one result is emitted at time t =
10 secs, whereas two batches are complete at this time.
Can you verify if this is the current behavior and if so fix it?
> Storm Trident support for sliding/tumbling windows
> --------------------------------------------------
>
> Key: STORM-676
> URL: https://issues.apache.org/jira/browse/STORM-676
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-core
> Reporter: Sriharsha Chintalapani
> Assignee: Satish Duggana
> Fix For: 1.0.0, 2.0.0
>
> Attachments: StormTrident_windowing_support-676.pdf
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)