aboutsummaryrefslogtreecommitdiff
path: root/dev
diff options
context:
space:
mode:
authorMarcelo Vanzin <vanzin@cloudera.com>2014-12-23 12:02:08 -0800
committerJosh Rosen <joshrosen@databricks.com>2014-12-23 12:02:08 -0800
commitdd155369a04d7dfbf6a5745cbb243e22218367dc (patch)
treee15ead7978c8bc91c590107f0f3d5d5852485fad /dev
parent2d215aebaad4b4596354f1543d997d06ef340bd5 (diff)
downloadspark-dd155369a04d7dfbf6a5745cbb243e22218367dc.tar.gz
spark-dd155369a04d7dfbf6a5745cbb243e22218367dc.tar.bz2
spark-dd155369a04d7dfbf6a5745cbb243e22218367dc.zip
[SPARK-4834] [standalone] Clean up application files after app finishes.
Commit 7aacb7bfa added support for sharing downloaded files among multiple executors of the same app. That works great in Yarn, since the app's directory is cleaned up after the app is done. But Spark standalone mode didn't do that, so the lock/cache files created by that change were left around and could eventually fill up the disk hosting /tmp. To solve that, create app-specific directories under the local dirs when launching executors. Multiple executors launched by the same Worker will use the same app directories, so they should be able to share the downloaded files. When the application finishes, a new message is sent to all workers telling them the application has finished; once that message has been received, and all executors registered for the application shut down, then those directories will be cleaned up by the Worker. Note: Unit testing this is hard (if even possible), since local-cluster mode doesn't seem to leave the Master/Worker daemons running long enough after `sc.stop()` is called for the clean up protocol to take effect. Author: Marcelo Vanzin <vanzin@cloudera.com> Closes #3705 from vanzin/SPARK-4834 and squashes the following commits: b430534 [Marcelo Vanzin] Remove seemingly unnecessary synchronization. 50eb4b9 [Marcelo Vanzin] Review feedback. c0e5ea5 [Marcelo Vanzin] [SPARK-4834] [standalone] Clean up application files after app finishes.
Diffstat (limited to 'dev')
0 files changed, 0 insertions, 0 deletions