Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.4.0
    • Component/s: None
    • Labels:
      None

      Description

      There is a race condition in incoming buffers, where it's possible for batches read off the wire could be left behind in the queue.

      We need to move the stream completion counter into the RawBatchBuffer getNext() method, which is single threaded.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              sphillips Steven Phillips
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: