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

Storm drops messages in the interval between server bind and callback registration

    XMLWordPrintableJSON

    Details

      Description

      This is one of the causes of unstable integration tests.

      When a worker starts, WorkerState boots up a Server, which binds Netty to a port in order to receive messages from other workers. Slightly later, we register a callback with the server that defines where the Server should deliver received messages.

      In the interim between binding the port and registering the callbacks, Storm quietly discards any received messages.

      Other workers will happily send messages to the worker that is not ready, as the sending side considers an open connection to be sufficient to send messages.

      We should change the setup so we set the receive callback before we start the Server.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                srdo Stig Rohde Døssing
                Reporter:
                srdo Stig Rohde Døssing
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

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