Spark Sql - исключение savestable - PullRequest
Новая
       15

Spark Sql - исключение savestable

0 голосов
/ 08 мая 2020

sparkversion: 2.3.0 scalaversion: 2.11.11 DevelopmentKit: Eclipse Oxygen Maven Project, попробовали поместить antlr-dependency (4.5.3) / (4.7) в pom. xml, но бесполезно, когда я использую фрейм данных как показано ниже, 

179      DF
180     .write
181     .mode(SaveMode.Append)
182     .format("parquet")strong text
183     .saveAsTable("%s.deepev_TripDivide".format(dbName))

кажется, что что-то не так, описание ошибки:

ANTLR Tool версии 4.7, используемой для генерации кода, не соответствует текущей версии 4.5.3 ANTLR Runtime версии 4.7, используемой для компиляция парсера не соответствует текущей версии среды выполнения 4.5.3Exception в потоке «main» java .lang.ExceptionInInitializerError в org. apache .spark. sql .catalyst.parser.AbstractSqlParser.parse (ParseDriver. scala : 84) в организации apache .spark. sql .execution.SparkSqlParser.parse (SparkSqlParser. scala: 48) в организации apache .spark. sql .catalyst.parser.AbstractSqlParser.parseTableIdentif (ParseDriver. scala: 49) в org. apache .spark. sql .DataFrameWriter.saveAsTable (DataFrameWriter. scala: 393) в com.reachauto.bussiness.Trip.TripDivide2 $ .run (TripDivide2. scala: 183) на com.reachauto.bu ssiness.Trip.StepTripDivide $ .run (StepTripDivide. scala: 18) на com.reachauto.main.main $$ anonfun $ main $ 6.apply (main. scala: 88) на com.reachauto.main.main $$ anonfun $ main $ 6.apply (main. scala: 85) в scala .collection.IndexedSeqOptimized $ class.foreach (IndexedSeqOptimized. scala: 33) в scala .collection.mutable.ArrayOps $ ofRef .foreach (ArrayOps. scala: 186) в com.reachauto.main.main $ .main (main. scala: 85) в com.reachauto.main.main.main (main. scala) Вызвано : java .lang.UnsupportedOperationException: java .io.InvalidClassException: org.antlr.v4.runtime.atn.ATN; Не удалось десериализовать ATN с UUID 59627784-3be5-417a-b9eb-8131a7286089 (ожидается aadb8d7e-aeef-4415-ad2b-8204d6cf042e или устаревший UUID). в org.antlr.v4.runtime.atn.ATNDeserializer.deserialize (ATNDeserializer. java: 153) в org. apache .spark. sql .catalyst.parser.SqlBaseLexer. (SqlBaseLexer. java: 1153 ) ... еще 12 Вызвано: java .io.InvalidClassException: org.antlr.v4.runtime.atn.ATN; Не удалось десериализовать ATN с UUID 59627784-3be5-417a-b9eb-8131a7286089 (ожидается aadb8d7e-aeef-4415-ad2b-8204d6cf042e или устаревший UUID). ... еще 14 я не использую antlr, так где же ошибка ?????

...