Open aijianiula0601 opened 6 years ago
if add the code below:
================ randomWalk.unpersist(blocking = false)
================to:
if (randomWalkPaths != null) { val prevRandomWalkPaths = randomWalkPaths randomWalkPaths = randomWalkPaths.union(randomWalk).cache() randomWalkPaths.first prevRandomWalkPaths.unpersist(blocking = false) randomWalk.unpersist(blocking = false) } else { randomWalkPaths = randomWalk }
what wrong happends after added?
if add the code below:
================ randomWalk.unpersist(blocking = false)
================to: