reduceByKey ergibt Infinity-Wert

Question

Ich versuche, Werte für denselben Schlüssel hinzuzufügen.

val final= d1.join(d2).flatMap(line => Seq(line.swap._1)).reduceByKey((x, y) =>(x+y)) 

D1 und D2 sind Datenströme. Nach flatMap erhalte ich Schlüsselwertpaar.

Es wird jedoch in Unendlich-Wert in dieser Zeile resultierenden reduceByKey((x, y) =>(x+y))

zum Beispiel, wenn die Paare (k1,1.0) (k1,1.0) die Linie reduceByKey((x, y) =>(x+y)) Ergebnisse in (k1, Unendlich)

Irgendwelche Vorschläge?

Answer 1

Das obige Code-Snippet funktioniert. Wie @maasg richtig andeutete, war das Problem woanders. Der Fehler wurde von division by zero im vorherigen Code verursacht, den ich hier nicht gepostet habe. Vielen Dank!