分享

Kudu报错ClassNotFoundException: org.apache.kudu.spark.kudu.KuduPartition

zhuqitian 发表于 2017-11-11 18:30:31 [显示全部楼层] 只看大图 回帖奖励 阅读模式 关闭右栏 1 15066
这几天想研究下kudu,感觉是下一代的存储系统
[mw_shl_code=scala,true]object Kudu_test extends App with Serializable {
import org.apache.kudu.client._
import org.apache.kudu.spark.kudu._
import org.apache.spark.sql.SparkSession  val ss = new SparkSession.Builder()
      .master("spark://192.168.0.104:7077")
      .config("spark.sql.warehouse.dir","/user/hive/warehouse")
      .getOrCreate()

  val df = ss.read.options(
    Map("kudu.master" -> "192.168.0.104:7051",
      "kudu.table" -> "impala::kudu_db.user_info")).kudu

  df.select("receivername").show()

  ss.stop()

}[/mw_shl_code]
很简单连接测试代码,maven也配置好了,但是运行报错:java.lang.ClassNotFoundException: org.apache.kudu.spark.kudu.KuduPartition
github上下载的kudu的源码也没有找到kudupartition类,哪位遇到了还望给我慷慨解惑

已有(1)人评论

跳转到指定楼层
langke93 发表于 2017-11-11 21:12:08
先看下源码是否有。这个源码是应该包含的尝试在添加一个语句
import org.apache.kudu.spark.kudu

源码的地方如下


yunama.jpg
https://git1-us-west.apache.org/ ... D.scala;hb=9acba45a
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条