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?