diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-05-01 17:41:55 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-01 17:41:55 -0700 |
| commit | ebc25a4ddfe07a67668217cec59893bc3b8cf730 (patch) | |
| tree | db4c85e869140c20ff1199042b91002273b96887 /streaming | |
| parent | 98e7045805282988da907793a844fa53d4c293c9 (diff) | |
| download | spark-ebc25a4ddfe07a67668217cec59893bc3b8cf730.tar.gz spark-ebc25a4ddfe07a67668217cec59893bc3b8cf730.tar.bz2 spark-ebc25a4ddfe07a67668217cec59893bc3b8cf730.zip | |
[SPARK-7309] [CORE] [STREAMING] Shutdown the thread pools in ReceivedBlockHandler and DAGScheduler
Shutdown the thread pools in ReceivedBlockHandler and DAGScheduler when stopping them.
Author: zsxwing <zsxwing@gmail.com>
Closes #5845 from zsxwing/SPARK-7309 and squashes the following commits:
6c004fd [zsxwing] Shutdown the thread pools in ReceivedBlockHandler and DAGScheduler
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala index 4b3d9ee4b0..651b534ac1 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala @@ -190,6 +190,7 @@ private[streaming] class WriteAheadLogBasedBlockHandler( def stop() { writeAheadLog.close() + executionContext.shutdown() } } |