Произошла ошибка при вызове o69.applySchemaToPythonRDD - PullRequest
Новая
       43

Произошла ошибка при вызове o69.applySchemaToPythonRDD

0 голосов
/ 17 декабря 2018

При попытке преобразовать Spark RDD в фрейм данных возникла следующая ошибка при запуске задания spark с использованием spark-submit.Это было для обоих методов преобразования RDD в DF -> createDataFrame () и toDF () 

    2018-12-17 11:31:50 INFO  StateStoreCoordinatorRef:54 - Registered StateStoreCoordinator endpoint
An error occurred while calling o69.applySchemaToPythonRDD.
: java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce$class
        at scala.reflect.internal.util.WeakHashSet.<init>(WeakHashSet.scala:19)
        at scala.reflect.internal.util.WeakHashSet$.apply(WeakHashSet.scala:429)
        at scala.reflect.internal.SymbolTable$perRunCaches$.<init>(SymbolTable.scala:310)
        at scala.reflect.internal.SymbolTable.perRunCaches$lzycompute(SymbolTable.scala:304)
        at scala.reflect.internal.SymbolTable.perRunCaches(SymbolTable.scala:304)
        at scala.reflect.internal.Symbols$class.$init$(Symbols.scala:71)
        at scala.reflect.internal.SymbolTable.<init>(SymbolTable.scala:13)
        at scala.reflect.runtime.JavaUniverse.<init>(JavaUniverse.scala:12)
        at scala.reflect.runtime.package$.universe$lzycompute(package.scala:16)
        at scala.reflect.runtime.package$.universe(package.scala:16)
        at org.apache.spark.sql.catalyst.ScalaReflection$.<init>(ScalaReflection.scala:47)
        at org.apache.spark.sql.catalyst.ScalaReflection$.<clinit>(ScalaReflection.scala)
        at org.apache.spark.sql.catalyst.encoders.RowEncoder$.org$apache$spark$sql$catalyst$encoders$RowEncoder$$serializerFor(RowEncoder.scala:74)
        at org.apache.spark.sql.catalyst.encoders.RowEncoder$.apply(RowEncoder.scala:61)
        at org.apache.spark.sql.Dataset$.ofRows(Dataset.scala:80)
        at org.apache.spark.sql.SparkSession.internalCreateDataFrame(SparkSession.scala:578)
        at org.apache.spark.sql.SparkSession.applySchemaToPythonRDD(SparkSession.scala:753)
        at org.apache.spark.sql.SparkSession.applySchemaToPythonRDD(SparkSession.scala:738)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
        at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
        at py4j.Gateway.invoke(Gateway.java:282)
        at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
        at py4j.commands.CallCommand.execute(CallCommand.java:79)
        at py4j.GatewayConnection.run(GatewayConnection.java:238)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: scala.collection.GenTraversableOnce$class
        at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        ... 29 more

Я использую Spark 2.4.0 с Hadoop 2.7.7.Версия Scala - 2.11.8 и Java 1.8.0_191.Используемая версия Python - 2.7.15.

Возможной причиной могла быть несовместимая версия Scala, но я думаю, что это не так.Соответственно, я предполагаю, что все эти заявленные версии фактически совместимы друг с другом, включая совместимость версии Scala для Spark.

Очень важно быстрое решение этой проблемы.

...