Skip to content

Commit bb5d324

Browse files
author
Marcelo Vanzin
committed
Merge branch 'master' into SPARK-4924
2 parents 53faef1 + a00af6b commit bb5d324

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ private[spark] class DiskBlockManager(blockManager: BlockManager, conf: SparkCon
166166
/** Cleanup local dirs and stop shuffle sender. */
167167
private[spark] def stop() {
168168
// Only perform cleanup if an external service is not serving our shuffle files.
169-
if (!blockManager.externalShuffleServiceEnabled) {
169+
if (!blockManager.externalShuffleServiceEnabled || blockManager.blockManagerId.isDriver) {
170170
localDirs.foreach { localDir =>
171171
if (localDir.isDirectory() && localDir.exists()) {
172172
try {

0 commit comments

Comments
 (0)