Spark Sql依赖报错:ClassNotFoundException: org.codehaus.janino.InternalCompilerException
Exception in thread “main” java.lang.NoClassDefFoundError: org/codehaus/janino/InternalCompilerException
at org.apache.spark.sql.catalyst.expressions.objects.GetExternalRowField.(objects.scala:1835)
at org.apache.spark.sql.catalyst.encoders.RowEncoder...anonfun$serializerFor3(RowEncoder.scala:186)atscala.collection.TraversableLike.3(RowEncoder.scala:186)
at scala.collection.TraversableLike.3(RowEncoder.scala:186)atscala.collection.TraversableLike.anonfun$flatMap1(TraversableLike.scala:293)atscala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:36)atscala.collection.IndexedSeqOptimized.foreach1(TraversableLike.scala:293)
at scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:36)
at scala.collection.IndexedSeqOptimized.foreach1(TraversableLike.scala:293)atscala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:36)atscala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOpsofRef.foreach(ArrayOps.scala:198)atscala.collection.TraversableLike.flatMap(TraversableLike.scala:293)atscala.collection.TraversableLike.flatMapofRef.foreach(ArrayOps.scala:198)
at scala.collection.TraversableLike.flatMap(TraversableLike.scala:293)
at scala.collection.TraversableLike.flatMapofRef.foreach(ArrayOps.scala:198)atscala.collection.TraversableLike.flatMap(TraversableLike.scala:293)atscala.collection.TraversableLike.flatMap(TraversableLike.scala:290)
at scala.collection.mutable.ArrayOpsofRef.flatMap(ArrayOps.scala:198)atorg.apache.spark.sql.catalyst.encoders.RowEncoderofRef.flatMap(ArrayOps.scala:198)
at org.apache.spark.sql.catalyst.encoders.RowEncoderofRef.flatMap(ArrayOps.scala:198)atorg.apache.spark.sql.catalyst.encoders.RowEncoder.serializerFor(RowEncoder.scala:183)
at org.apache.spark.sql.catalyst.encoders.RowEncoder.apply(RowEncoder.scala:72)atorg.apache.spark.sql.Dataset.apply(RowEncoder.scala:72)
at org.apache.spark.sql.Dataset.apply(RowEncoder.scala:72)atorg.apache.spark.sql.Dataset.anonfunanonfunanonfunofRows1(Dataset.scala:91)atorg.apache.spark.sql.SparkSession.withActive(SparkSession.scala:775)atorg.apache.spark.sql.Dataset1(Dataset.scala:91)
at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:775)
at org.apache.spark.sql.Dataset1(Dataset.scala:91)atorg.apache.spark.sql.SparkSession.withActive(SparkSession.scala:775)atorg.apache.spark.sql.Dataset.ofRows(Dataset.scala:88)
at org.apache.spark.sql.SparkSession.baseRelationToDataFrame(SparkSession.scala:440)
at org.apache.spark.sql.execution.datasources.json.TextInputJsonDataSource.createBaseDataset(JsonDataSource.scala:124)atorg.apache.spark.sql.execution.datasources.json.TextInputJsonDataSource.createBaseDataset(JsonDataSource.scala:124)
at org.apache.spark.sql.execution.datasources.json.TextInputJsonDataSource.createBaseDataset(JsonDataSource.scala:124)atorg.apache.spark.sql.execution.datasources.json.TextInputJsonDataSource.infer(JsonDataSource.scala:97)
at org.apache.spark.sql.execution.datasources.json.JsonDataSource.inferSchema(JsonDataSource.scala:65)
at org.apache.spark.sql.execution.datasources.json.JsonFileFormat.inferSchema(JsonFileFormat.scala:59)
at org.apache.spark.sql.execution.datasources.DataSource.anonfunanonfunanonfungetOrInferFileFormatSchema11(DataSource.scala:210)atscala.Option.orElse(Option.scala:447)atorg.apache.spark.sql.execution.datasources.DataSource.getOrInferFileFormatSchema(DataSource.scala:207)atorg.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:411)atorg.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:274)atorg.apache.spark.sql.DataFrameReader.11(DataSource.scala:210)
at scala.Option.orElse(Option.scala:447)
at org.apache.spark.sql.execution.datasources.DataSource.getOrInferFileFormatSchema(DataSource.scala:207)
at org.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:411)
at org.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:274)
at org.apache.spark.sql.DataFrameReader.11(DataSource.scala:210)atscala.Option.orElse(Option.scala:447)atorg.apache.spark.sql.execution.datasources.DataSource.getOrInferFileFormatSchema(DataSource.scala:207)atorg.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:411)atorg.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:274)atorg.apache.spark.sql.DataFrameReader.anonfun$load3(DataFrameReader.scala:245)atscala.Option.getOrElse(Option.scala:189)atorg.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:245)atorg.apache.spark.sql.DataFrameReader.json(DataFrameReader.scala:405)atorg.apache.spark.sql.DataFrameReader.json(DataFrameReader.scala:386)atcom.atguigu.sparksql.CreateDataFrame3(DataFrameReader.scala:245)
at scala.Option.getOrElse(Option.scala:189)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:245)
at org.apache.spark.sql.DataFrameReader.json(DataFrameReader.scala:405)
at org.apache.spark.sql.DataFrameReader.json(DataFrameReader.scala:386)
at com.atguigu.sparksql.CreateDataFrame3(DataFrameReader.scala:245)atscala.Option.getOrElse(Option.scala:189)atorg.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:245)atorg.apache.spark.sql.DataFrameReader.json(DataFrameReader.scala:405)atorg.apache.spark.sql.DataFrameReader.json(DataFrameReader.scala:386)atcom.atguigu.sparksql.CreateDataFrame.main(CreateDataFrame.scala:11)
at com.atguigu.sparksql.CreateDataFrame.main(CreateDataFrame.scala)
Caused by: java.lang.ClassNotFoundException: org.codehaus.janino.InternalCompilerException
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:355)
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
… 31 more
Caused by: java.lang.ClassNotFoundException: org.codehaus.janino.InternalCompilerException:使用的spark 版本冲突,原因是使用的spark的版本为3.2.1 的,Spark 3.2.1 需要 Janino 3.0.16(官方兼容版本),而非 3.1.6
<dependency>
<groupId>org.codehaus.janino</groupId>
<artifactId>janino</artifactId>
<version>3.0.16</version>
</dependency>
<dependency>
<groupId>org.codehaus.janino</groupId>
<artifactId>commons-compiler</artifactId>
<version>3.0.16</version>
</dependency>
调整后完美解决问题!!!
更多推荐




所有评论(0)