使用scala访问hbaseconfiguration方法时出现问题

rjzwgtxy  于 2021-06-09  发布在  Hbase
关注(0)|答案(1)|浏览(199)

我正在尝试实现spark流,以便将kafka主题添加到hbase中
我导入了下面的行“import org.apache.hadoop.hbase.{hbaseconfiguration,htabledescriptor,hcolumndescriptor}”
val hconf=新的hbaseconfiguration()
直到这一点上没有错误,但在下一行,当我试图设置如下配置属性
hconf.set(“hbase.zookeeper.quorum”,”localhost:2182")
我收到错误“value set不是org.apache.hadoop.hbase.hbaseconfiguration的成员”
我只是按照上面的链接
https://acadgild.com/blog/building-a-real-time-application-using-kafka-and-spark
为了实现这一点
你能告诉我如何解决这个错误吗。
你好,苏德尔

4urapxun

4urapxun1#

resolved:as my maven中的hadoop JAR已损坏。我只是删除了“c:\users\user1.m2\repository\org\apache\hadoop”下的文件。我再次重建项目以添加依赖项。然后我就可以从hadoop依赖项访问配置了…希望它能帮到人!

相关问题