[jira] [Created] (STORM-3362) EventHubSpout uses a blocking receiver in nextTuple()

[York Yang (JIRA)]

York Yang created STORM-3362:
--------------------------------

             Summary: EventHubSpout uses a blocking receiver in nextTuple()
                 Key: STORM-3362
                 URL: https://issues.apache.org/jira/browse/STORM-3362
             Project: Apache Storm
          Issue Type: Bug
            Reporter: York Yang


As title indicates, the line below:

eventDatawrap = partitionManager.receive();

when I dig into it, it's a blocking call which affects ack and fail messages. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)