org.apache.spark.sql.catalyst.catalog.ExternalCatalog as super class

一、報錯

在進行SparkSql代碼調(diào)試時,代碼確認無誤執(zhí)行報如下錯誤:
Exception in thread "main" java.lang.IncompatibleClassChangeError: class org.apache.spark.sql.hive.HiveExternalCatalog has interface org.apache.spark.sql.catalyst.catalog.ExternalCatalog as super class

Exception in thread "main" java.lang.IncompatibleClassChangeError: class org.apache.spark.sql.hive.HiveExternalCatalog has interface org.apache.spark.sql.catalyst.catalog.ExternalCatalog as super class
    at java.lang.ClassLoader.defineClass1(Native Method)
    at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
    at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
    at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
    at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:348)
    at org.apache.spark.util.Utils$.classForName(Utils.scala:239)
    at org.apache.spark.sql.internal.StaticSQLConf$.defaultHiveCatalogImplementation(StaticSQLConf.scala:49)
    at org.apache.spark.sql.internal.StaticSQLConf$$anonfun$3.apply(StaticSQLConf.scala:41)
    at org.apache.spark.sql.internal.StaticSQLConf$$anonfun$3.apply(StaticSQLConf.scala:41)
    at scala.Option.getOrElse(Option.scala:121)
    at org.apache.spark.internal.config.ConfigEntryWithDefaultFunction.readFrom(ConfigEntry.scala:103)
    at org.apache.spark.SparkConf.get(SparkConf.scala:261)
    at org.apache.spark.sql.SparkSession$.org$apache$spark$sql$SparkSession$$sessionStateClassName(SparkSession.scala:1074)
    at org.apache.spark.sql.SparkSession$$anonfun$sessionState$2.apply(SparkSession.scala:155)
    at org.apache.spark.sql.SparkSession$$anonfun$sessionState$2.apply(SparkSession.scala:153)
    at scala.Option.getOrElse(Option.scala:121)
    at org.apache.spark.sql.SparkSession.sessionState$lzycompute(SparkSession.scala:153)
    at org.apache.spark.sql.SparkSession.sessionState(SparkSession.scala:150)
    at org.apache.spark.sql.DataFrameReader.<init>(DataFrameReader.scala:787)
    at org.apache.spark.sql.SparkSession.read(SparkSession.scala:664)
    at com.kkb.spark.sparkSql.ReadTextFile$.main(ReadTextFile.scala:14)
    at com.kkb.spark.sparkSql.ReadTextFile.main(ReadTextFile.scala)
二、解決方案

在網(wǎng)上找不到該報錯的相關(guān)文章(估計這個錯誤太low了),經(jīng)檢查發(fā)現(xiàn)pom.xml配置了兩個不同版本的spark-hive_2.11依賴,將其中一個注釋后執(zhí)行正常

        <dependency>
            <groupId>org.apache.spark</groupId>
            <artifactId>spark-sql_2.11</artifactId>
            <version>2.4.0-cdh6.2.0</version>
        </dependency>
<!--        <dependency>-->
<!--            <groupId>org.apache.spark</groupId>-->
<!--            <artifactId>spark-hive_2.11</artifactId>-->
<!--            &lt;!&ndash;                        <version>2.4.0-cdh6.2.0</version>&ndash;&gt;-->
<!--            <version>2.3.3</version>-->
<!--        </dependency>-->
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容