我试图在spark集群上运行一个用java编写的spark作业,将记录作为Dataframe加载到我创建的配置单元表中。
df.write().mode("overwrite").insertInto(dbname.tablename);
尽管配置单元中存在表和数据库,但它抛出以下错误:org.apache.spark.sql.analysisexception:找不到表或视图:dbname.tablename,数据库dbname不存在。;
我还尝试从与上表不同的现有配置单元表中读取数据,认为在创建表时可能会出现问题。我还检查了我的用户是否有权访问hive存储数据的hdfs文件夹。一切看起来都很好,不确定是什么问题。
请建议。
谢谢
1条答案
按热度按时间mlnl4t2r1#
我想它是在星火里找那张table,而不是在Hive里。