Hbase Cannot get replica 0 location for

[hadoop@hadoop01 nt]$ flink run -m yarn-cluster -yjm 1024m -ytm 2024m-c xxxxxx xxxxx.jar# TaskManager 报错如下：# 具体是在进行 hbase#connection = HBaseConn.getHBaseConn();#table = connection.getTable(tableName);

胖胖胖胖胖虎

2351人浏览 · 2021-07-16 10:37:36

胖胖胖胖胖虎 · 2021-07-16 10:37:36 发布

[hadoop@hadoop01 nt]$ flink run -m yarn-cluster -yjm 1024m -ytm 2024m  -c xxxxxx xxxxx.jar


# TaskManager 报错如下：
# 具体是在进行 hbase 
#  connection = HBaseConn.getHBaseConn();
#  table = connection.getTable(tableName);
#  table.put(puts);//put提交操作 

2021-07-15 14:59:26,947 ERROR org.apache.hadoop.hbase.client.AsyncRequestFutureImpl        [] - Cannot get replica 0 location for {"totalColumns":22,"row":"230a0102-202105271501180012","families":{"info":[{"qualifier":"deviceIp","vlen":12,"tag":[],"timestamp":9223372036854775807},{"qualifier":"ucch","vlen":5,"tag":[],"timestamp":9223372036854775807},{"qualifier":"unum","vlen":4,"tag":[],"timestamp":9223372036854775807},{"qualifier":"mac","vlen":8,"tag":[],"timestamp":9223372036854775807}]},"ts":9223372036854775807}

Cannot get replica 0 location for 一顿搜索无果、纠结了半天…

尝试进行 table.get 操作，依次报 ClassNotFound，加入以下两个jar到Flink lib，成功运行…

Caused by: java.lang.NoClassDefFoundError: org/apache/htrace/core/HTraceConfiguration
        at org.apache.hadoop.hbase.client.ResultBoundedCompletionService.submit(ResultBoundedCompletionService.java:171)
        at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.addCallsForCurrentReplica(ScannerCallableWithReplicas.java:320)
        at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.call(ScannerCallableWithReplicas.java:182)
        at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.call(ScannerCallableWithReplicas.java:58)
        at org.apache.hadoop.hbase.client.RpcRetryingCallerImpl.callWithoutRetries(RpcRetryingCallerImpl.java:191)
        ... 26 more
#####################

Caused by: java.lang.NoClassDefFoundError: com/codahale/metrics/Metric
        at org.apache.hadoop.hbase.ipc.AbstractRpcClient.callMethod(AbstractRpcClient.java:402)
        at org.apache.hadoop.hbase.ipc.AbstractRpcClient.callBlockingMethod(AbstractRpcClient.java:328)
        at org.apache.hadoop.hbase.ipc.AbstractRpcClient.access$200(AbstractRpcClient.java:95)
        at org.apache.hadoop.hbase.ipc.AbstractRpcClient$BlockingRpcChannelImplementation.callBlockingMethod(AbstractRpcClient.java:571)
        at org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos$ClientService$BlockingStub.scan(ClientProtos.java:42534)
        at org.apache.hadoop.hbase.client.ScannerCallable.openScanner(ScannerCallable.java:332)
        at org.apache.hadoop.hbase.client.ScannerCallable.rpcCall(ScannerCallable.java:242)
        at org.apache.hadoop.hbase.client.ScannerCallable.rpcCall(ScannerCallable.java:58)
        at org.apache.hadoop.hbase.client.RegionServerCallable.call(RegionServerCallable.java:127)
        at org.apache.hadoop.hbase.client.RpcRetryingCallerImpl.callWithoutRetries(RpcRetryingCallerImpl.java:191)
        ... 7 more