What's the correct way to use setCallSite to get the change to show up in
the spark logs?

I have something like

class RichRDD (rdd : RDD[MyThing]) {
   def mySpecialOperation() {
       rdd.context.setCallSite("bubbles and candy!")
       rdd.map(....)
       val result = rdd.groupBy(....)
       rdd.context.clearCallSite()
       result
    }
}


But when I use .mySpecialOperation "bubbles and candy!" doesn't seem to
show up anywhere in the logs. Is this not the right way to use
.setCallSite?

Reply via email to