Skip to content

Commit 2ab7aa8

Browse files
ukby1234mridulm
andauthored
Update core/src/main/scala/org/apache/spark/storage/BlockManagerDecommissioner.scala
Co-authored-by: Mridul Muralidharan <[email protected]>
1 parent 9887cd3 commit 2ab7aa8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ private[storage] class BlockManagerDecommissioner(
149149
fallbackStorage.foreach(_.copy(shuffleBlockInfo, bm))
150150
} catch {
151151
case e: FileNotFoundException =>
152-
logWarning("Skipping block $shuffleBlockInfo, block deleted.", e)
152+
logWarning(s"Skipping block $shuffleBlockInfo, block deleted.", e)
153153
case NonFatal(e) =>
154154
logError(s"Fallback storage for $shuffleBlockInfo failed", e)
155155
keepRunning = false

0 commit comments

Comments
 (0)