[
https://issues.apache.org/jira/browse/FLINK-37212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jonasjc updated FLINK-37212:
----------------------------
Description:
*Problem:*
when hbase region move,hbase connector throw the following exception:
{code:java}
Caused by:
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.DoNotRetryIOException:
Unable to load exception received from
server:org.apache.hadoop.hbase.NotServingRegionException at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.ipc.RemoteWithExtrasException.unwrapRemoteException(RemoteWithExtrasException.java:85)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.protobuf.ProtobufUtil.makeIOExceptionOfException(ProtobufUtil.java:282)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.protobuf.ProtobufUtil.handleRemoteException(ProtobufUtil.java:269)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.RegionServerCallable.call(RegionServerCallable.java:129)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.RpcRetryingCallerImpl.callWithRetries(RpcRetryingCallerImpl.java:107)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.HTable.get(HTable.java:384)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.HTable.get(HTable.java:358)
at
org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction.lookup(HBaseRowDataLookupFunction.java:98)
... 18 moreCaused by:
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.ipc.RemoteWithExtrasException(org.apache.hadoop.hbase.NotServingRegionException):
org.apache.hadoop.hbase.NotServingRegionException:
DIM:jichun_test_dim,,1736922383279.ebbf1db8150deec82662ff4087dbcc67. is not
online on dw-t1-ops-hadoop-test-015.shizhuang-inc.net,16020,1736822942551 at
org.apache.hadoop.hbase.regionserver.HRegionServer.getRegionByEncodedName(HRegionServer.java:3462)
at
org.apache.hadoop.hbase.regionserver.HRegionServer.getRegion(HRegionServer.java:3439)
at
org.apache.hadoop.hbase.regionserver.RSRpcServices.getRegion(RSRpcServices.java:1488)
at
org.apache.hadoop.hbase.regionserver.RSRpcServices.get(RSRpcServices.java:2561)
at
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:45815)
at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:392) at
org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:133) at
org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:359) at
org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:339)
{code}
*Cause:*
it cause by : org.apache.hadoop.hbase.NotServingRegionException had been
relocate to
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.NotServingRegionException
and can not fond the class `org.apache.hadoop.hbase.NotServingRegionException`
from error message fo hbase sever
*Fix:*
don't relocate class 'org.apache.hadoop.hbase.NotServingRegionException'
was:
*Problem:*
when hbase region move,hbase connector throw the following exception:
{code:java}
Caused by:
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.DoNotRetryIOException:
Unable to load exception received from
server:org.apache.hadoop.hbase.NotServingRegionException at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.ipc.RemoteWithExtrasException.unwrapRemoteException(RemoteWithExtrasException.java:85)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.protobuf.ProtobufUtil.makeIOExceptionOfException(ProtobufUtil.java:282)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.protobuf.ProtobufUtil.handleRemoteException(ProtobufUtil.java:269)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.RegionServerCallable.call(RegionServerCallable.java:129)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.RpcRetryingCallerImpl.callWithRetries(RpcRetryingCallerImpl.java:107)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.HTable.get(HTable.java:384)
at
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.HTable.get(HTable.java:358)
at
org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction.lookup(HBaseRowDataLookupFunction.java:98)
... 18 moreCaused by:
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.ipc.RemoteWithExtrasException(org.apache.hadoop.hbase.NotServingRegionException):
org.apache.hadoop.hbase.NotServingRegionException:
DIM:jichun_test_dim,,1736922383279.ebbf1db8150deec82662ff4087dbcc67. is not
online on dw-t1-ops-hadoop-test-015.shizhuang-inc.net,16020,1736822942551 at
org.apache.hadoop.hbase.regionserver.HRegionServer.getRegionByEncodedName(HRegionServer.java:3462)
at
org.apache.hadoop.hbase.regionserver.HRegionServer.getRegion(HRegionServer.java:3439)
at
org.apache.hadoop.hbase.regionserver.RSRpcServices.getRegion(RSRpcServices.java:1488)
at
org.apache.hadoop.hbase.regionserver.RSRpcServices.get(RSRpcServices.java:2561)
at
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:45815)
at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:392) at
org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:133) at
org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:359) at
org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:339)
{code}
*Cause:*
it cause by : org.apache.hadoop.hbase.NotServingRegionException had been
relocate to
org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.NotServingRegionException
and can not fond the class 'org.apache.hadoop.hbase.NotServingRegionException'
from error message fo hbase sever
*Fix:*
don't relocate class 'org.apache.hadoop.hbase.NotServingRegionException'
> Hbase connector "Unable to load exception received from
> server:org.apache.hadoop.hbase.NotServingRegionException"
> -----------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-37212
> URL: https://issues.apache.org/jira/browse/FLINK-37212
> Project: Flink
> Issue Type: Bug
> Components: Connectors / HBase
> Affects Versions: hbase-4.0.0
> Reporter: jonasjc
> Priority: Major
>
> *Problem:*
> when hbase region move,hbase connector throw the following exception:
> {code:java}
> Caused by:
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.DoNotRetryIOException:
> Unable to load exception received from
> server:org.apache.hadoop.hbase.NotServingRegionException at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.ipc.RemoteWithExtrasException.unwrapRemoteException(RemoteWithExtrasException.java:85)
> at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.protobuf.ProtobufUtil.makeIOExceptionOfException(ProtobufUtil.java:282)
> at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.protobuf.ProtobufUtil.handleRemoteException(ProtobufUtil.java:269)
> at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.RegionServerCallable.call(RegionServerCallable.java:129)
> at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.RpcRetryingCallerImpl.callWithRetries(RpcRetryingCallerImpl.java:107)
> at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.HTable.get(HTable.java:384)
> at
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.HTable.get(HTable.java:358)
> at
> org.apache.flink.connector.hbase.source.HBaseRowDataLookupFunction.lookup(HBaseRowDataLookupFunction.java:98)
> ... 18 moreCaused by:
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.ipc.RemoteWithExtrasException(org.apache.hadoop.hbase.NotServingRegionException):
> org.apache.hadoop.hbase.NotServingRegionException:
> DIM:jichun_test_dim,,1736922383279.ebbf1db8150deec82662ff4087dbcc67. is not
> online on dw-t1-ops-hadoop-test-015.shizhuang-inc.net,16020,1736822942551
> at
> org.apache.hadoop.hbase.regionserver.HRegionServer.getRegionByEncodedName(HRegionServer.java:3462)
> at
> org.apache.hadoop.hbase.regionserver.HRegionServer.getRegion(HRegionServer.java:3439)
> at
> org.apache.hadoop.hbase.regionserver.RSRpcServices.getRegion(RSRpcServices.java:1488)
> at
> org.apache.hadoop.hbase.regionserver.RSRpcServices.get(RSRpcServices.java:2561)
> at
> org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:45815)
> at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:392) at
> org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:133) at
> org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:359)
> at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:339)
> {code}
>
> *Cause:*
> it cause by : org.apache.hadoop.hbase.NotServingRegionException had been
> relocate to
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.NotServingRegionException
> and can not fond the class
> `org.apache.hadoop.hbase.NotServingRegionException` from error message fo
> hbase sever
>
> *Fix:*
> don't relocate class 'org.apache.hadoop.hbase.NotServingRegionException'
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
