Print call site information for broadcasts

shivaram · shivaram · commit cd6dbdf66eeb · 2014-10-16T11:32:36.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -815,6 +815,8 @@ class SparkContext(config: SparkConf) extends Logging {
    */
   def broadcast[T: ClassTag](value: T): Broadcast[T] = {
     val bc = env.broadcastManager.newBroadcast[T](value, isLocal)
+    val callSite = getCallSite
+    logInfo("Created broadcast " + bc.id + " from " + callSite.shortForm)
     cleaner.foreach(_.registerBroadcastForCleanup(bc))
     bc
   }

Original file line number	Diff line number	Diff line change
`@@ -815,6 +815,8 @@ class SparkContext(config: SparkConf) extends Logging {`
`815`	`815`	`*/`
`816`	`816`	`def broadcast[T: ClassTag](value: T): Broadcast[T] = {`
`817`	`817`	`val bc = env.broadcastManager.newBroadcast[T](value, isLocal)`
	`818`	`+ val callSite = getCallSite`
	`819`	`+ logInfo("Created broadcast " + bc.id + " from " + callSite.shortForm)`
`818`	`820`	`cleaner.foreach(_.registerBroadcastForCleanup(bc))`
`819`	`821`	`bc`
`820`	`822`	`}`