diff options
author | KaiXinXiaoLei <huleilei1@huawei.com> | 2015-10-15 14:48:01 -0700 |
---|---|---|
committer | Andrew Or <andrew@databricks.com> | 2015-10-15 14:48:01 -0700 |
commit | 2d000124b72d0ff9e3ecefa03923405642516c4c (patch) | |
tree | 0fc0e761fb31e48284307e0bff4ba4b736cfc645 /bin/spark-shell | |
parent | 723aa75a9d566c698aa49597f4f655396fef77bd (diff) | |
download | spark-2d000124b72d0ff9e3ecefa03923405642516c4c.tar.gz spark-2d000124b72d0ff9e3ecefa03923405642516c4c.tar.bz2 spark-2d000124b72d0ff9e3ecefa03923405642516c4c.zip |
[SPARK-10515] When killing executor, the pending replacement executors should not be lost
If the heartbeat receiver kills executors (and new ones are not registered to replace them), the idle timeout for the old executors will be lost (and then change a total number of executors requested by Driver), So new ones will be not to asked to replace them.
For example, executorsPendingToRemove=Set(1), and executor 2 is idle timeout before a new executor is asked to replace executor 1. Then driver kill executor 2, and sending RequestExecutors to AM. But executorsPendingToRemove=Set(1,2), So AM doesn't allocate a executor to replace 1.
see: https://github.com/apache/spark/pull/8668
Author: KaiXinXiaoLei <huleilei1@huawei.com>
Author: huleilei <huleilei1@huawei.com>
Closes #8945 from KaiXinXiaoLei/pendingexecutor.
Diffstat (limited to 'bin/spark-shell')
0 files changed, 0 insertions, 0 deletions