Skip to content

Commit 75ab18e

Browse files
committed
comment fixes
1 parent e6baa25 commit 75ab18e

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,8 @@ private[spark] class TorrentBroadcast[T: ClassTag](obj: T, id: Long, serializedO
143143
// regressions if an internal broadcast is accessed on the driver, we store a soft
144144
// reference to the broadcasted value:
145145
_value = new SoftReference[T](value)
146-
} else { // Store a copy of the broadcast variable in the driver so that tasks run on the driver
146+
} else {
147+
// Store a copy of the broadcast variable in the driver so that tasks run on the driver
147148
// do not create a duplicate copy of the broadcast variable's value.
148149
if (!blockManager.putSingle(broadcastId, value, MEMORY_AND_DISK, tellMaster = false)) {
149150
throw new SparkException(s"Failed to store $broadcastId in BlockManager")

sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/BroadcastExchangeExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ case class BroadcastExchangeExec(
166166
val beforeBroadcast = System.nanoTime()
167167
longMetric("buildTime") += NANOSECONDS.toMillis(beforeBroadcast - beforeBuild)
168168

169-
// SPARK-39983 - Broadcast the relation without caching the unserialized value.
169+
// SPARK-39983 - Broadcast the relation without caching the unserialized object.
170170
val broadcasted = sparkContext.broadcastInternal(relation, serializedOnly = true)
171171
longMetric("broadcastTime") += NANOSECONDS.toMillis(
172172
System.nanoTime() - beforeBroadcast)

0 commit comments

Comments
 (0)