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

set TOPOLOGY_MAX_SPOUT_PENDING to one,but can get more than one tuple in bolt

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Not A Problem
    • 0.10.2
    • None
    • storm-kafka
    • None

    Description

      Spout in the nextTuple may pull more than one kafka message, will remain in the _waitingToEmit, and then launch one by one, even if the TOPOLOGY_MAX_SPOUT_PENDING set to 1, when the first tuple is defeated, the bolt will still receive follow-up Message until _waitingToEmit is completely transmitted.

      This and I think TOPOLOGY_MAX_SPOUT_PENDING is not the same meaning, I hope that the message can be strictly processed one by one, my topology worker number, spout and bolt parallelism are set to 1

      Attachments

        Activity

          People

            Unassigned Unassigned
            wu.yong@neusoft.com wu.yong@neusoft.com
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: