Ich bin neu in Scala und Funke. Heute habe ich versucht, etwas Code zu schreiben, und ließ es auf Funken laufen, aber bekam eine Ausnahme.
Dieser Code funktioniert in lokaler Scala
%Vor%aber wenn ich diesen Code in funken setze, wirft es eine Ausnahme auf:
%Vor%Wenn ich den folgenden Code auskommentiere, funktioniert der Code in funken
%Vor%kann jemand bitte erklären, warum.
Danke @Imm, ich habe dieses Problem gelöst. Der Grund dafür ist, dass meine lokale Scala 2.11.4 ist, aber mein Funke-Cluster läuft in Version 1.2.0. Die 1.2-Version von Spark wurde von 2.10 scala zusammengestellt.
Also ist die Lösung kompilieren lokalen Code von 2.10 Scala, und laden Sie das kompilierte Glas in Spark. Alles funktioniert gut.
Tags und Links scala apache-spark