[jira] [Created] (STORM-3693) TimeOut ticks should be addressed to Executor instead of being addressed to a task or broadcasted.

["Chandan Kumar Singh (Jira)" <ji...@apache.org>]

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)