Skip to content

[SPARK-4714][CORE]: Check block have removed or not after got info lock in dropFromMemory #3574

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
suyanNone wants to merge 3 commits into from
Closed

[SPARK-4714][CORE]: Check block have removed or not after got info lock in dropFromMemory #3574

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e57e270
add check info is already remove or not while having gotten info.syn
suyanNone Dec 3, 2014
55fa4ba
refine code
suyanNone Dec 8, 2014
edb989d
Refine code style and comments position
suyanNone Dec 9, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion core/src/main/scala/org/apache/spark/storage/BlockManager.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1014,8 +1014,10 @@ private[spark] class BlockManager(
// If we get here, the block write failed.
logWarning(s"Block $blockId was marked as failure. Nothing to drop")
return None
} else if (blockInfo.get(blockId).isEmpty) {
logWarning(s"Block $blockId was already dropped.")
return None
}

var blockIsUpdated = false
val level = info.level

Expand Down