Skip to content

[SPARK-12685] [MLlib] word2vec trainWordsCount gets overflow #10627

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
hhbyyh wants to merge 4 commits into from
Closed

[SPARK-12685] [MLlib] word2vec trainWordsCount gets overflow #10627

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
e2d8387
fix overflow in word2vec
hhbyyh Jan 7, 2016
67561e2
Merge remote-tracking branch 'upstream/master' into w2voverflow
hhbyyh Jan 11, 2016
8172a80
Merge remote-tracking branch 'upstream/master' into w2voverflow
hhbyyh Jan 11, 2016
f8901b6
change wordCount to Long
hhbyyh Jan 11, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
change wordCount to Long
  • Loading branch information
@hhbyyh
hhbyyh committed Jan 11, 2016
commit f8901b66b69ff0adf9c8d7a3793ada604cbc269a
2 changes: 1 addition & 1 deletion mllib/src/main/scala/org/apache/spark/mllib/feature/Word2Vec.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -332,7 +332,7 @@ class Word2Vec extends Serializable with Logging {
val random = new XORShiftRandom(seed ^ ((idx + 1) << 16) ^ ((-k - 1) << 8))
val syn0Modify = new Array[Int](vocabSize)
val syn1Modify = new Array[Int](vocabSize)
val model = iter.foldLeft((bcSyn0Global.value, bcSyn1Global.value, 0, 0)) {
val model = iter.foldLeft((bcSyn0Global.value, bcSyn1Global.value, 0L, 0L)) {
case ((syn0, syn1, lastWordCount, wordCount), sentence) =>
var lwc = lastWordCount
var wc = wordCount
Expand Down