Skip to content

Commit 6390b6c

Browse files
committed
Fix NumericParser
1 parent bc74297 commit 6390b6c

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,8 +103,9 @@ object SparkKMeans {
103103
spark.stop()
104104
}
105105

106-
private def mergeResults(a: (Vector[Double], Int),
107-
b: (Vector[Double], Int)): (Vector[Double], Int) = {
106+
private def mergeResults(
107+
a: (Vector[Double], Int),
108+
b: (Vector[Double], Int)): (Vector[Double], Int) = {
108109
(a._1 + b._1, a._2 + b._2)
109110
}
110111
}

mllib/src/main/scala/org/apache/spark/mllib/util/NumericParser.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,10 +85,10 @@ private[mllib] object NumericParser {
8585
while (parsing && tokenizer.hasMoreTokens()) {
8686
token = tokenizer.nextToken()
8787
if (token == "(") {
88-
items ++= parseTuple(tokenizer)
88+
items += parseTuple(tokenizer)
8989
allowComma = true
9090
} else if (token == "[") {
91-
items ++= parseArray(tokenizer)
91+
items += parseArray(tokenizer)
9292
allowComma = true
9393
} else if (token == ",") {
9494
if (allowComma) {

0 commit comments

Comments
 (0)