You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@storm.apache.org by "York Yang (JIRA)" <ji...@apache.org> on 2019/03/25 22:58:00 UTC

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

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)