node2vec
node2vec copied to clipboard
The variable name as "randomWalk" in node2vec can not unpersist after second iter problem.
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?