我是靠谱客的博主 秀丽哈密瓜,这篇文章主要介绍spark1.6升级2.3读取hive表报错NoSuchDatabaseException: Database 'ods' not found,现在分享给大家,希望可以做个参考。

升级完spark后,通过spark-submit 操作hive报错,如下:

org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException: Database 'ods' not found;
        at org.apache.spark.sql.catalyst.catalog.SessionCatalog.org$apache$spark$sql$catalyst$catalog$SessionCatalog$$requireDbExists(SessionCatalog.scala:174)
        at org.apache.spark.sql.catalyst.catalog.SessionCatalog.setCurrentDatabase(SessionCatalog.scala:256)
        at org.apache.spark.sql.execution.command.SetDatabaseCommand.run(databases.scala:59)
        at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult$lzycompute(commands.scala:70)
        at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult(commands.scala:68)
        at org.apache.spark.sql.execution.command.ExecutedCommandExec.executeCollect(commands.scala:79)
        at org.apache.spark.sql.Dataset$$anonfun$6.apply(Dataset.scala:190)
        at org.apache.spark.sql.Dataset$$anonfun$6.apply(Dataset.scala:190)
        at org.apache.spark.sql.Dataset$$anonfun$52.apply(Dataset.scala:3259)
        at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:77)
        at org.apache.spark.sql.Dataset.withAction(Dataset.scala:3258)
        at org.apache.spark.sql.Dataset.<init>(Dataset.scala:190)
        at org.apache.spark.sql.Dataset$.ofRows(Dataset.scala:75)
        at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:642)

搜索后有的说是

SparkSession没有加 enableHiveSupport(),但是我的已经加了

但是spark-shell可以操作hive,通过对比环境,发现spark-shell的spark.sql.catalogImplementation=hive

而spark-submit后的没有这个配置,而此配置默认是im-memory,并不是hive

于是修改submit配置添加--conf spark.sql.catalogImplementation=hive后,问题解决。

最后

以上就是秀丽哈密瓜最近收集整理的关于spark1.6升级2.3读取hive表报错NoSuchDatabaseException: Database 'ods' not found的全部内容,更多相关spark1.6升级2.3读取hive表报错NoSuchDatabaseException:内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(163)

评论列表共有 0 条评论

立即
投稿
返回
顶部