Chandan Kumar Singh created STORM-3693:
------------------------------------------
Summary: 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
Fix For: 2.2.1
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)
