diff options
| author | Mark Hamstra <markhamstra@gmail.com> | 2014-05-06 12:53:39 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@databricks.com> | 2014-05-06 12:53:39 -0700 |
| commit | fbfe69de69aa6767d95167711622ec34c59a1f6d (patch) | |
| tree | 5a57a06c21070e4f672664d9157342ddf4e284d5 /python/pyspark/java_gateway.py | |
| parent | 7b978c1ac59718b85e512c46105b6af641afc3dc (diff) | |
| download | spark-fbfe69de69aa6767d95167711622ec34c59a1f6d.tar.gz spark-fbfe69de69aa6767d95167711622ec34c59a1f6d.tar.bz2 spark-fbfe69de69aa6767d95167711622ec34c59a1f6d.zip | |
[SPARK-1685] Cancel retryTimer on restart of Worker or AppClient
See https://issues.apache.org/jira/browse/SPARK-1685 for a more complete description, but in essence: If the Worker or AppClient actor restarts before successfully registering with Master, multiple retryTimers will be running, which will lead to less than the full number of registration retries being attempted before the new actor is forced to give up.
Author: Mark Hamstra <markhamstra@gmail.com>
Closes #602 from markhamstra/SPARK-1685 and squashes the following commits:
11cc088 [Mark Hamstra] retryTimer -> registrationRetryTimer
69c348c [Mark Hamstra] Cancel retryTimer on restart of Worker or AppClient
Diffstat (limited to 'python/pyspark/java_gateway.py')
0 files changed, 0 insertions, 0 deletions