Github user AnthonyTruchet commented on a diff in the pull request:
https://github.com/apache/spark/pull/14299#discussion_r71723751
--- Diff:
mllib/src/main/scala/org/apache/spark/mllib/feature/Word2Vec.scala ---
@@ -313,133 +313,139 @@ class Word2Vec extends Serializable with Logg
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/14299#discussion_r71703375
--- Diff:
mllib/src/main/scala/org/apache/spark/mllib/feature/Word2Vec.scala ---
@@ -313,133 +313,139 @@ class Word2Vec extends Serializable with Logging {
GitHub user AnthonyTruchet opened a pull request:
https://github.com/apache/spark/pull/14299
Ensure broadcasted variables are destroyed even in case of exception
## What changes were proposed in this pull request?
Ensure broadcasted variable are destroyed even in case of exc