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>

调整后完美解决问题!!!

更多推荐