Skip to content

Commit cf547b3

Browse files
jiangxb1987Robert Kruszewski
authored andcommitted
[MINOR][CORE] Show block manager id when remove RDD/Broadcast fails.
## What changes were proposed in this pull request? Address apache#20924 (comment), show block manager id when remove RDD/Broadcast fails. ## How was this patch tested? N/A Author: Xingbo Jiang <[email protected]> Closes apache#20960 from jiangxb1987/bmid.
1 parent 33b5849 commit cf547b3

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,8 @@ class BlockManagerMasterEndpoint(
164164
val futures = blockManagerInfo.values.map { bm =>
165165
bm.slaveEndpoint.ask[Int](removeMsg).recover {
166166
case e: IOException =>
167-
logWarning(s"Error trying to remove RDD $rddId", e)
167+
logWarning(s"Error trying to remove RDD $rddId from block manager ${bm.blockManagerId}",
168+
e)
168169
0 // zero blocks were removed
169170
}
170171
}.toSeq
@@ -195,7 +196,8 @@ class BlockManagerMasterEndpoint(
195196
val futures = requiredBlockManagers.map { bm =>
196197
bm.slaveEndpoint.ask[Int](removeMsg).recover {
197198
case e: IOException =>
198-
logWarning(s"Error trying to remove broadcast $broadcastId", e)
199+
logWarning(s"Error trying to remove broadcast $broadcastId from block manager " +
200+
s"${bm.blockManagerId}", e)
199201
0 // zero blocks were removed
200202
}
201203
}.toSeq

0 commit comments

Comments
 (0)