[
https://issues.apache.org/jira/browse/STORM-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ethan Li updated STORM-3693:
----------------------------
Fix Version/s: (was: 2.2.1)
> TimeOut ticks should be addressed to Executor instead of being addressed to a
> task or broadcasted.
> ---------------------------------------------------------------------------------------------------
>
> Key: STORM-3693
> URL: https://issues.apache.org/jira/browse/STORM-3693
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-client
> Affects Versions: 2.1.0
> Reporter: Chandan Kumar Singh
> Priority: Major
> Time Spent: 20m
> Remaining Estimate: 0h
>
> For the purpose of message timeouts, a spout executor uses a rotating map,
> irrespective of the number of spout tasks it is dealing with. When a time out
> tick tuple is received, it is broadcasted to all the tasks which means we
> rotate the map as many times as the number of assigned tasks and expire
> tuples prematurely. We need the tuple to be neither a broadcast not addressed
> to any task. The executor should act on it only once.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
