首页 > 解决方案 > HBaseTableCatalog.tableCatalog 显示错误 - Symbol 'term类路径中缺少 .yetus.audience'。如何解决这个问题?

问题描述

我的输入是HBase表格。首先我正在加载数据和函数withCatalog将返回Dataframe

def withCatalog(cat: String): DataFrame = {
  sqlContext
    .read
    .options(Map(HBaseTableCatalog.tableCatalog -> cat))
    .format("org.apache.hadoop.hbase.spark")
    .load()
}
val allrulesDF = withCatalog("personDb:employeeTable")
allrulesDF.show()

HBaseTableCatalog显示以下错误的行

标签: scalaapache-sparkapache-spark-sqlhbase

解决方案


这是由于 spark 无法加载 hbase jar。

如果你使用 hbase2.1+,你可以在 path 中找到 jar like audience-annotations-*.jar 等等$HBASE_HOME/lib/client-facing-thirdparty

并将这些罐子移动到火花罐路径。


推荐阅读