gengliangwang commented on code in PR #46309: URL: https://github.com/apache/spark/pull/46309#discussion_r1585624924
########## core/src/main/scala/org/apache/spark/storage/BlockManagerDecommissioner.scala: ########## @@ -319,7 +321,7 @@ private[storage] class BlockManagerDecommissioner( deadPeers.foreach(migrationPeers.get(_).foreach(_.keepRunning = false)) // If we don't have anyone to migrate to give up if (!migrationPeers.values.exists(_.keepRunning)) { - logWarning("No available peers to receive Shuffle blocks, stop migration.") + logWarning(log"No available peers to receive Shuffle blocks, stop migration.") Review Comment: ditto ########## core/src/main/scala/org/apache/spark/storage/BlockManagerDecommissioner.scala: ########## @@ -351,7 +353,7 @@ private[storage] class BlockManagerDecommissioner( logInfo(s"Need to replicate ${replicateBlocksInfo.size} RDD blocks " + "for block manager decommissioning") } else { - logWarning(s"Asked to decommission RDD cache blocks, but no blocks to migrate") + logWarning(log"Asked to decommission RDD cache blocks, but no blocks to migrate") Review Comment: ditto -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org