[SPARK-7236] AkkaUtils askWithReply sleeps indefinitely when a timeout exception is thrown

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.4.0
• Component/s: Spark Core
• Labels: quickfix
• Assignee: Bryan Cutler
• Reporter: Bryan Cutler
• Created: 29/Apr/15 15:31
• Updated: 05/May/15 01:30
• Resolved: 05/May/15 01:30

Description

When AkkaUtils.askWithReply gets a TimeoutException, the default parameters maxAttempts = 1 and retryInterval = Int.MaxValue lead to the thread sleeping for a good while.

I noticed this issue when testing for SPARK-6980 and using this function without invoking Spark jobs, so perhaps it acts differently in another context.

If this function is on its final attempt to ask and it fails, it should return immediately. Also, perhaps a better default retryInterval would be 0.

Issue Links

• links to: [Github] Pull Request #5896 (BryanCutler)