Lorenzo Affetti created STORM-1964:
--------------------------------------
Summary: Unexpected behavior when using count window together with
timestamp extraction
Key: STORM-1964
URL: https://issues.apache.org/jira/browse/STORM-1964
Project: Apache Storm
Issue Type: Bug
Components: storm-core
Affects Versions: 1.0.1
Reporter: Lorenzo Affetti
Priority: Minor
I launched a topology applying a tumbling count window of size 2 (watermark
interval 200ms, lag 1s) with the following input:
70
60
20 50
10 30 40 80 90 100 values
|———|———|———|———|———|—————> time
10 11 12 13 14 15
timestamps [s]
And I got these windows as output (the format for a tuple is (timestamp,
value)):
[(10,10), (10,20)]
[(12,60), (12,70)]
[(12,60), (12,70)] // why (60, 70) 2 times?
[(13,80), (14,90)]
I would expect something like:
[(10,10), (10,20)]
[(11,30), (12,40)]
[(12,50), (12,60)]
[(12,70), (13,80)]
[(14,90), (15,100)]
It seems like that timestamp extraction and count windows does not fit each
other.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
