[
https://issues.apache.org/jira/browse/SPARK-7236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bryan Cutler updated SPARK-7236:
--------------------------------
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}}.
was:
When {{AkkaUtils.askWithReply}} gets a TimeoutException, the default parameters
{{maxAttempts = 1}} and {{retryInterval = Int.Max}} 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}}.
> AkkaUtils askWithReply sleeps indefinitely when a timeout exception is thrown
> -----------------------------------------------------------------------------
>
> Key: SPARK-7236
> URL: https://issues.apache.org/jira/browse/SPARK-7236
> Project: Spark
> Issue Type: Bug
> Components: Spark Core
> Reporter: Bryan Cutler
> Priority: Trivial
> Labels: quickfix
> Attachments: SparkLongSleepAfterTimeout.scala
>
>
> 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}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
