Skip to content

Commit 0aafba2

Browse files
committed
Add comment to explain that doPut() does not overwrite existing block.
1 parent 51e1b2e commit 0aafba2

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -726,6 +726,8 @@ private[spark] class BlockManager(
726726
* Put the given block according to the given level in one of the block stores, replicating
727727
* the values if necessary.
728728
*
729+
* If the block already exists, this method will not overwrite it.
730+
*
729731
* @param effectiveStorageLevel the level according to which the block will actually be handled.
730732
* This allows the caller to specify an alternate behavior of doPut
731733
* while preserving the original level specified by the user.

0 commit comments

Comments
 (0)