diff options
author | Terence Yim <terence@cask.co> | 2016-04-12 13:46:39 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-04-12 13:46:39 -0700 |
commit | 3e53de4bdd6d7b6de1fe3e5bfbdc53180aa9a737 (patch) | |
tree | e02718d2767554e986f3765dff9c5241c8a5d319 /streaming/src | |
parent | bcd2076274b1a95f74616d0ceacb0696e38b5f4c (diff) | |
download | spark-3e53de4bdd6d7b6de1fe3e5bfbdc53180aa9a737.tar.gz spark-3e53de4bdd6d7b6de1fe3e5bfbdc53180aa9a737.tar.bz2 spark-3e53de4bdd6d7b6de1fe3e5bfbdc53180aa9a737.zip |
[SPARK-14513][CORE] Fix threads left behind after stopping SparkContext
## What changes were proposed in this pull request?
Shutting down `QueuedThreadPool` used by Jetty `Server` to avoid threads leakage after SparkContext is stopped.
Note: If this fix is going to apply to the `branch-1.6`, one more patch on the `NettyRpcEnv` class is needed so that the `NettyRpcEnv._fileServer.shutdown` is called in the `NettyRpcEnv.cleanup` method. This is due to the removal of `_fileServer` field in the `NettyRpcEnv` class in the master branch. Please advice if a second PR is necessary for bring this fix back to `branch-1.6`
## How was this patch tested?
Ran the ./dev/run-tests locally
Author: Terence Yim <terence@cask.co>
Closes #12318 from chtyim/fixes/SPARK-14513-thread-leak.
Diffstat (limited to 'streaming/src')
0 files changed, 0 insertions, 0 deletions