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?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
