[STORM-2705] DRPCSpout sleeps twice when idle

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0, 1.2.0, 1.1.2, 1.0.5
• Component/s: storm-core
• Assignee: Daniel Klessing
• Reporter: Daniel Klessing
• Created: 23/Aug/17 13:59
• Updated: 25/Aug/17 05:55
• Resolved: 25/Aug/17 05:55

Description

Profiling our topology I noticed that the DRPCSpout actually sleeps twice if it has nothing to do. This is due to a Utils.sleep(1) call at the end of nextTuple() while the SleepSpoutWaitStrategy performs the default sleep if a spout did not emit any tuple.

This causes - in my understanding - unnecessary context switches, especially with a high number of parallelism.

Attached the corresponding YourKit screenshot.

Issue Links

• links to: GitHub Pull Request #2292