在尝试运行与Hadoop集群中的HBase表通信的Scala API (使用Play构建)时,我遇到了一个问题。当我启动二进制文件时,它是正常的,但当我试图访问网页时,我得到了这个错误:
Could not initialize class org.apache.hadoop.hbase.protobuf.ProtobufUtil
c0f68942ce3b654568a63a5bde43f86f|HCBGGB|BAAMUS00000000872391|PCOBGB00000000389099, type=INCREMENT at org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil.toIncr
我使用这个代码示例来读取使用Spark的hbase表,唯一的改变是通过代码添加hbase.zookeeper.quorum,因为它不是从hbase-site.xml中挑选它。at org.apache.hadoop.hbase.protobuf.RequestConverter.buildRegionSpecifier(RequestConverter.java:921):132)
at org.apache.hadoop.hbase.protobuf.ProtobufUtil.getR
当我使用“火花流”读取"kafka“(需要sasl验证)并将数据存储到"HBase”时,"HBase“会出现以下错误
org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(Task.scala:99) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:325) at java.util.concurrent.Th