这不是flink的问题,之前遇到过相关问题 hbase region分裂的时候 会出现此类问题  你可以看看日志是否hbase region当时正在分裂,  










在 2020-05-28 16:57:35,"air23" <wangfei23_...@163.com> 写道:




2020-05-28 16:54:23,867 INFO  
org.apache.hadoop.hbase.client.AsyncRequestFutureImpl         - id=2, 
table=GC_SCHEM:mon1, attempt=7/16, failureCount=427ops, last 
exception=org.apache.hadoop.hbase.RegionTooBusyException: 
org.apache.hadoop.hbase.RegionTooBusyException: Above memstore limit, 
regionName=GC_SCHEM:mon1,,1590655288228.89343281db3d32d630482b536933121c., 
server=zongteng75,60020,1590565532547, memstoreSize=575455635, 
blockingMemStoreSize=536870912

  at 
org.apache.hadoop.hbase.regionserver.HRegion.checkResources(HRegion.java:3777)

  at org.apache.hadoop.hbase.regionserver.HRegion.batchMutate(HRegion.java:2935)

  at org.apache.hadoop.hbase.regionserver.HRegion.batchMutate(HRegion.java:2886)

  at 
org.apache.hadoop.hbase.regionserver.RSRpcServices.doBatchOp(RSRpcServices.java:765)

  at 
org.apache.hadoop.hbase.regionserver.RSRpcServices.doNonAtomicRegionMutation(RSRpcServices.java:716)

  at 
org.apache.hadoop.hbase.regionserver.RSRpcServices.multi(RSRpcServices.java:2146)

  at 
org.apache.hadoop.hbase.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:33656)

  at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:2191)

  at org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:112)

  at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:183)

  at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:163)

 on zongteng75,60020,1590565532547, tracking started null, retrying 
after=4037ms, operationsToReplay=427





 

回复