Note that, using window functions currently requires a HiveContext;是的,切换到HiveContext工作,我没有注意到在代码开头初始化了SparkContext和SQLContext,而不是使用HiveContext切换SQLContext,我尝试在SparkContext之外创建一个新的HiveContext:
val hiveCo
司机的HiveContext试图连接到一个不存在的蜂巢转移。这是弄坏了司机。阻止火花的HiveContext试图连接到Hive的最佳方式是什么?例如,未设置特定环境属性?$lzycompute(HiveContext.scala:241)
at org.apache.spark.sql.hive.HiveContext.sessionState(HiveContext.scala<init>(HiveContext.scala:38
setMaster("local")val sqlContext = new TestHiveContext(sc) // tried new HiveContext<init>(ClientWrapper.scala:120)
[scalatest] at org.apache.spark.sql.hive.HiveContext.executionHive$lzycompute(HiveContext.scala