Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-3693

TimeOut ticks should be addressed to Executor instead of being addressed to a task or broadcasted.

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 2.1.0
    • Fix Version/s: 2.2.1
    • Component/s: storm-client
    • Labels:
      None

      Description

      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. 

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              Chandan83 Chandan Kumar Singh

              Dates

              • Created:
                Updated:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 20m
                20m

                  Issue deployment