我的输入是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
行
classpath.
中缺少符号term <none>.yetus.audience
此符号是<none>
所必需的。确保术语受众位于类路径中,并检查与-Ylog-classpath
的依赖关系是否冲突。如果HBaseTableCatalog.class
针对不兼容的<none>.yetus
版本进行编译,则完全重建可能会有所帮助。类路径中缺少符号
term org.apache.yetus
。此符号是<none>
所必需的。确保术语 yetus 在您的类路径中,并检查与-Ylog-classpath
的冲突依赖关系。如果HBaseTableCatalog.class
针对不兼容的org.apache
版本编译,则完全重建可能会有所帮助。
这是由于火花无法加载hbase罐。
如果使用 hbase2.1+,可以在路径$HBASE_HOME/lib/client-facing-thirdparty
中找到 jar 喜欢的受众注释-*.jar 等。
并移动这些罐子以激发罐子路径。