Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19556#discussion_r146895438
--- Diff: core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala ---
@@ -395,8 +435,13 @@ private[util] class FieldAccessFinder(
if (!visitedMethods.contains(m)) {
// Keep track of visited methods to avoid potential infinite
cycles
visitedMethods += m
- ClosureCleaner.getClassReader(cl).accept(
- new FieldAccessFinder(fields, findTransitively, Some(m),
visitedMethods), 0)
+
+ var currentClass = cl
+ do {
--- End diff --
here too
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
