@青牛 老师，hive-site.xml是这样的，我该怎么配置啊，试了好多博客了，我的环境是zookeper+hive1.2.1+spark2.1.0+hadoop2.7.3

@青牛 加了，现在是这个错：
java.lang.IllegalArgumentException: Wrong FS: hdfs://master:9000/user/root/tmp/links/part-00000-6d815b22-729c-451d-827f-139f1c0caba3.snappy.parquet, expected: file:///

@青牛
是我的hive集群没有搭建好还是什么原因嘛？
hive是照着这个博客配的
https://blog.csdn.net/lovebyz/article/details/83346458?from=singlemessage&isappinstalled=0

@青牛 不是，是hdfs上的数据，代码如下：

def main(args:Array[String]){
val localclusterURL="local[2]"
val clusterMasterURL="spark://master:7077"
val conf=new SparkConf().setAppName("ETL").setMaster(clusterMasterURL)
val sc =new SparkContext(conf)
val sqlContext=new SQLContext(sc)
val hc =new HiveContext(sc)
import sqlContext.implicits._

//设置RDDdepartions的数量一般以集群分配给应用的cpu核数的整数被为宜
val minPartitions= 8
//links
val links = sc.textFile("data/links.txt", minPartitions).filter {!_.endsWith(",")}
.map(_.split(","))
.map(x => Links(x(0).trim.toInt, x(1).trim.toInt, x(2).trim().toInt))
.toDF()

links.write.mode(SaveMode.Overwrite).parquet("/tmp/links");
hc.sql("drop table if exists links")
hc.sql("create table if not exists links(movieId int,ImdbId int,tmdbId int ) stored as parquet")
hc.sql("load data inpath '/tmp/links' overwrite into table links")

环境是spark2.1.0，但是我用的是1.x的语法

Please help me, I am scraching my head since last week and still no luck.

在线等

牛牛们，救我