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

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Labels: pull-request-available
• Assignee: Jungtaek Lim
• Reporter: York Yang
• Created: 25/Mar/19 22:57
• Updated: 29/Mar/19 03:54
• Resolved: 29/Mar/19 03:54

Description

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. 

Issue Links

• links to: GitHub Pull Request #2981