diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2016-05-04 21:19:53 -0700 |
---|---|---|
committer | Shixiong Zhu <shixiong@databricks.com> | 2016-05-04 21:19:53 -0700 |
commit | bde27b89a243247bd3069b24cb4bb1eee94edfd7 (patch) | |
tree | 6a966dc41531913f8a08bfb2a137066a1cf1d6de /python/test_support | |
parent | ef55e46c9225ddceebeaf19398519cbe651c1728 (diff) | |
download | spark-bde27b89a243247bd3069b24cb4bb1eee94edfd7.tar.gz spark-bde27b89a243247bd3069b24cb4bb1eee94edfd7.tar.bz2 spark-bde27b89a243247bd3069b24cb4bb1eee94edfd7.zip |
[SPARK-15131][SQL] Shutdown StateStore management thread when SparkContext has been shutdown
## What changes were proposed in this pull request?
Make sure that whenever the StateStoreCoordinator cannot be contacted, assume that the SparkContext and RpcEnv on the driver has been shutdown, and therefore stop the StateStore management thread, and unload all loaded stores.
## How was this patch tested?
Updated unit tests.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #12905 from tdas/SPARK-15131.
Diffstat (limited to 'python/test_support')
0 files changed, 0 insertions, 0 deletions