Skip to content

Commit add61d8

Browse files
author
Mingfei
committed
Set externalBlockStoreInitialized to be true, after ExternalBlockStore is initialized
1 parent eacd4a9 commit add61d8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,10 @@ private[spark] class BlockManager(
8383
private var externalBlockStoreInitialized = false
8484
private[spark] val memoryStore = new MemoryStore(this, maxMemory)
8585
private[spark] val diskStore = new DiskStore(this, diskBlockManager)
86-
private[spark] lazy val externalBlockStore: ExternalBlockStore =
86+
private[spark] lazy val externalBlockStore: ExternalBlockStore = {
87+
externalBlockStoreInitialized = true
8788
new ExternalBlockStore(this, executorId)
89+
}
8890

8991
private[spark]
9092
val externalShuffleServiceEnabled = conf.getBoolean("spark.shuffle.service.enabled", false)

0 commit comments

Comments
 (0)