We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0628a33 commit b963178Copy full SHA for b963178
core/src/main/scala/org/apache/spark/storage/BlockInfoManager.scala
@@ -323,8 +323,11 @@ private[storage] class BlockInfoManager extends Logging {
323
infos(blockId) = newBlockInfo
324
newBlockInfo.writerTask = currentTaskAttemptId
325
writeLocksByTask.addBinding(currentTaskAttemptId, blockId)
326
+ logTrace(s"Task $currentTaskAttemptId successfully locked new block $blockId")
327
true
328
} else {
329
+ logTrace(s"Task $currentTaskAttemptId did not create and lock block $blockId " +
330
+ s"because that block already exists")
331
false
332
}
333
0 commit comments