@@ -270,7 +270,7 @@ private[spark] object ClosureCleaner extends Logging {
270270 }
271271 }
272272
273- logDebug(s " + fields accessed by starting closure: " + accessedFields.size)
273+ logDebug(s " + fields accessed by starting closure: ${ accessedFields.size} classes " )
274274 accessedFields.foreach { f => logDebug(" " + f) }
275275
276276 // List of outer (class, object) pairs, ordered from outermost to innermost
@@ -380,7 +380,7 @@ private[spark] object ClosureCleaner extends Logging {
380380 initAccessedFields(accessedFields, Seq (capturingClass))
381381 IndylambdaScalaClosures .findAccessedFields(lambdaProxy, classLoader, accessedFields)
382382
383- logDebug(s " + fields accessed by starting closure: " + accessedFields.size)
383+ logDebug(s " + fields accessed by starting closure: ${ accessedFields.size} classes " )
384384 accessedFields.foreach { f => logDebug(" " + f) }
385385
386386 if (accessedFields(capturingClass).size < capturingClass.getDeclaredFields.length) {
@@ -516,7 +516,7 @@ private[spark] object IndylambdaScalaClosures extends Logging {
516516
517517 val visited = Set [MethodIdentifier [_]](implMethodId)
518518 val stack = Stack [MethodIdentifier [_]](implMethodId)
519- while (! stack.isEmpty) {
519+ while (! stack.isEmpty) {
520520 val currentId = stack.pop
521521 val currentMethodNode = methodsByName(currentId)
522522 logTrace(s " scanning $currentId" )
0 commit comments