使用 scala 访问 HbaseConfiguration 方法时出现问题
Issue in accessing HbaseConfiguration method using scala
我正在尝试实现 spark streaming 以将 kafka 主题添加到 hbase.when 我正在 scala eclipse 中使用 Maven 实现，我遇到了以下问题
我导入了以下行
"import org.apache.hadoop.hbase.{HBaseConfiguration,HTableDescriptor,HColumnDescriptor}"
val hConf = new HBaseConfiguration()
到目前为止没有错误，但是在下一行，当我尝试设置如下所示的配置属性时
hConf.set("hbase.zookeeper.quorum", "localhost:2182")
我遇到错误 "value set is not a member of org.apache.hadoop.hbase.HBaseConfiguration"
我只是按照上面的link
https://acadgild.com/blog/building-a-real-time-application-using-kafka-and-spark
为了实现这个
能否告诉我如何解决此错误。
此致，
苏德希尔
已解决：由于我在 maven 中的 hadoop jar 得到 corrupted.Simply 我删除了 "C:\Users\user1.m2\repository\org\apache\hadoop" 下的文件。我再次重建项目以添加 dependencies.Then 我能够访问来自 hadoop 依赖项的配置....希望它对某人有所帮助！
我正在尝试实现 spark streaming 以将 kafka 主题添加到 hbase.when 我正在 scala eclipse 中使用 Maven 实现，我遇到了以下问题
我导入了以下行 "import org.apache.hadoop.hbase.{HBaseConfiguration,HTableDescriptor,HColumnDescriptor}"
val hConf = new HBaseConfiguration()
到目前为止没有错误，但是在下一行，当我尝试设置如下所示的配置属性时
hConf.set("hbase.zookeeper.quorum", "localhost:2182")
我遇到错误 "value set is not a member of org.apache.hadoop.hbase.HBaseConfiguration"
我只是按照上面的link
https://acadgild.com/blog/building-a-real-time-application-using-kafka-and-spark
为了实现这个
能否告诉我如何解决此错误。
此致， 苏德希尔
已解决：由于我在 maven 中的 hadoop jar 得到 corrupted.Simply 我删除了 "C:\Users\user1.m2\repository\org\apache\hadoop" 下的文件。我再次重建项目以添加 dependencies.Then 我能够访问来自 hadoop 依赖项的配置....希望它对某人有所帮助！