diff options
author | Marcelo Vanzin <vanzin@cloudera.com> | 2015-04-21 20:33:57 -0400 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2015-04-21 20:33:57 -0400 |
commit | e72c16e30d85cdc394d318b5551698885cfda9b8 (patch) | |
tree | 9b450a7f27b311e5bd5b776e8aee2af96e3408d3 /python/pyspark/sql/tests.py | |
parent | b063a61b9852cf9b9d2c905332d2ecb2fd716cc4 (diff) | |
download | spark-e72c16e30d85cdc394d318b5551698885cfda9b8.tar.gz spark-e72c16e30d85cdc394d318b5551698885cfda9b8.tar.bz2 spark-e72c16e30d85cdc394d318b5551698885cfda9b8.zip |
[SPARK-6014] [core] Revamp Spark shutdown hooks, fix shutdown races.
This change adds some new utility code to handle shutdown hooks in
Spark. The main goal is to take advantage of Hadoop 2.x's API for
shutdown hooks, which allows Spark to register a hook that will
run before the one that cleans up HDFS clients, and thus avoids
some races that would cause exceptions to show up and other issues
such as failure to properly close event logs.
Unfortunately, Hadoop 1.x does not have such APIs, so in that case
correctness is still left to chance.
Author: Marcelo Vanzin <vanzin@cloudera.com>
Closes #5560 from vanzin/SPARK-6014 and squashes the following commits:
edfafb1 [Marcelo Vanzin] Better scaladoc.
fcaeedd [Marcelo Vanzin] Merge branch 'master' into SPARK-6014
e7039dc [Marcelo Vanzin] [SPARK-6014] [core] Revamp Spark shutdown hooks, fix shutdown races.
Diffstat (limited to 'python/pyspark/sql/tests.py')
0 files changed, 0 insertions, 0 deletions