-
- Downloads
[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.
Showing
- core/src/main/scala/org/apache/spark/deploy/history/HistoryServer.scala 2 additions, 4 deletions...scala/org/apache/spark/deploy/history/HistoryServer.scala
- core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala 4 additions, 8 deletions...scala/org/apache/spark/deploy/worker/ExecutorRunner.scala
- core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala 5 additions, 13 deletions...ain/scala/org/apache/spark/storage/DiskBlockManager.scala
- core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala 11 additions, 13 deletions.../scala/org/apache/spark/storage/TachyonBlockManager.scala
- core/src/main/scala/org/apache/spark/util/Utils.scala 118 additions, 18 deletionscore/src/main/scala/org/apache/spark/util/Utils.scala
- core/src/test/scala/org/apache/spark/util/UtilsSuite.scala 24 additions, 8 deletionscore/src/test/scala/org/apache/spark/util/UtilsSuite.scala
- sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala 2 additions, 7 deletions...pache/spark/sql/hive/thriftserver/HiveThriftServer2.scala
- sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala 2 additions, 7 deletions...pache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala 27 additions, 36 deletions...cala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
Loading
Please register or sign in to comment