我试图使用spark.sql（“”）在spark shell上提取配置单元表数据，但它给出了空值。配置单元表包含数据。即使我已经使用hivecontext对象编写了代码，但同样的问题仍然存在。
xxls0lw81#
hc=SQLContext(sc) hc.sql("select * from <dbname>.<tablename> ").show()
laik7k3q2#
是否可以尝试将spark.sql.warehouse.dir设置为配置单元仓库目录的目录，而不是/user/hive/warehouse，并将hive.metastore.uris设置为旧版服务器
val spark = SparkSession .builder() .appName("YourName") .config("spark.sql.warehouse.dir", "/user/hive/warehouse") .config("hive.metastore.uris", "thrift://localhost:9083") .enableHiveSupport() .getOrCreate()
2条答案
按热度按时间xxls0lw81#
laik7k3q2#
是否可以尝试将spark.sql.warehouse.dir设置为配置单元仓库目录的目录，而不是/user/hive/warehouse，并将hive.metastore.uris设置为旧版服务器