我正在尝试连接sparksql和配置单元,以便可以使用sparksql查询配置单元表。这是我的程序:
SparkSession spark = SparkSession
.builder()
.appName("Java Spark Hive Example")
.master("local[*]")
.config("hive.metastore.uris", "thrift://localhost:9083")
.enableHiveSupport()
.getOrCreate();
try{
spark.sql("select * from health").show();}
catch(Exception AnalysisException){ System.out.println("table not found");}
但是我在运行程序时遇到了一个问题。问题是:
问题是:https://justpaste.it/13n4r
我已经检查了我的笔记本电脑上的相同代码,它运行良好。但是当我切换到我的desptop计算机时,我在使用EclipseNeon运行maven程序时遇到了这个问题。
我使用的是ApacheSpark2.1.0和Hive1.2.0
由于版本不同,这不是一个问题。我确信这一点。但我不明白问题是什么,我能做些什么来避免它。请帮帮我。
暂无答案!
目前还没有任何答案,快来回答吧!