@Duo Zhang
This means that you're writing too fast and memstore has reached its upper 
limit. Is the flush and compaction fine at RS side?

-> No, flush took very long time.
I attach code that took a long time to run. (about 30min)

https://github.com/apache/hbase/blob/branch-1.2/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java#L2424-L2508

Best regards,
Minwoo Kang
________________________________________
보낸 사람: Kang Minwoo <[email protected]>
보낸 날짜: 2018년 5월 23일 수요일 15:16
받는 사람: [email protected]
제목: Re: can not write to HBase

I am using salt, prevent write hotspot.
And Table has 4000 regions.

HBase version is 1.2.6.

I attach code that took a long time to run. (about 30min)
https://github.com/apache/hbase/blob/branch-1.2/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java#L2424-L2508

Best regards,
Minwoo Kang

________________________________________
보낸 사람: Anil Gupta <[email protected]>
보낸 날짜: 2018년 5월 23일 수요일 14:13
받는 사람: [email protected]
제목: Re: can not write to HBase

It seems you might have a write hotspot.
Are your writes evenly distributed across the cluster? Do you have more than 
15-20 regions for that table?

Sent from my iPhone

&gt; On May 22, 2018, at 9:52 PM, Kang Minwoo <[email protected]> wrote:
&gt;
&gt; I think hbase flush is too slow.
&gt; so memstore reached upper limit.
&gt;
&gt; flush took about 30min.
&gt; I don't know why flush is too long.
&gt;
&gt; Best regards,
&gt; Minwoo Kang
&gt;
&gt; ________________________________________
&gt; 보낸 사람: 张铎(Duo Zhang) <[email protected]>
&gt; 보낸 날짜: 2018년 5월 23일 수요일 11:37
&gt; 받는 사람: hbase-user
&gt; 제목: Re: can not write to HBase
&gt;
&gt; org.apache.hadoop.hbase.RegionTooBusyException:
&gt; org.apache.hadoop.hbase.RegionTooBusyException:
&gt; Above memstore limit, regionName={region}, server={server},
&gt; memstoreSize=2600502128, blockingMemStoreSize=2600468480
&gt;
&gt; This means that you're writing too fast and memstore has reached its upper
&gt; limit. Is the flush and compaction fine at RS side?
&gt;
&gt; 2018-05-23 10:20 GMT+08:00 Kang Minwoo <[email protected]>:
&gt;
&gt;&gt; attach client exception and stacktrace.
&gt;&gt;
&gt;&gt; I've looked more.
&gt;&gt; It seems to be the reason why it takes 1290 seconds to flush in the 
Region
&gt;&gt; Server.
&gt;&gt;
&gt;&gt; 2018-05-23T07:24:31.202 [INFO] Call exception, tries=34, retries=35,
&gt;&gt; started=513393 ms ago, cancelled=false, msg=row '{row}' on table 
'{table}'
&gt;&gt; at region={region}, hostname={host}, seqNum=155455658
&gt;&gt; 2018-05-23T07:24:31.208 [ERROR]
&gt;&gt; java.lang.RuntimeException: com.google.protobuf.ServiceException: Error
&gt;&gt; calling method MultiRowMutationService.MutateRows
&gt;&gt;        at 
com.google.common.base.Throwables.propagate(Throwables.java:160)
&gt;&gt; ~[stormjar.jar:?]
&gt;&gt;        at ...
&gt;&gt;        at org.apache.storm.daemon.executor$fn__8058$tuple_
&gt;&gt; action_fn__8060.invoke(executor.clj:731) [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at 
org.apache.storm.daemon.executor$mk_task_receiver$fn__7979.invoke(executor.clj:464)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at 
org.apache.storm.disruptor$clojure_handler$reify__7492.onEvent(disruptor.clj:40)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at 
org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:451)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at org.apache.storm.utils.DisruptorQueue.
&gt;&gt; consumeBatchWhenAvailable(DisruptorQueue.java:430)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at 
org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at 
org.apache.storm.daemon.executor$fn__8058$fn__8071$fn__8124.invoke(executor.clj:850)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
&gt;&gt; [storm-core-1.0.2.jar:1.0.2]
&gt;&gt;        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
&gt;&gt;        at java.lang.Thread.run(Thread.java:745) [?:1.7.0_80]
&gt;&gt; Caused by: com.google.protobuf.ServiceException: Error calling method
&gt;&gt; MultiRowMutationService.MutateRows
&gt;&gt;        at org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel.
&gt;&gt; callBlockingMethod(CoprocessorRpcChannel.java:75) ~[stormjar.jar:?]
&gt;&gt;        at org.apache.hadoop.hbase.protobuf.generated.
&gt;&gt; MultiRowMutationProtos$MultiRowMutationService$BlockingStub.mutateRows(
&gt;&gt; MultiRowMutationProtos.java:2149) ~[stormjar.jar:?]
&gt;&gt;        at ...
&gt;&gt;        ... 13 more
&gt;&gt; Caused by: org.apache.hadoop.hbase.client.RetriesExhaustedException:
&gt;&gt; Failed after attempts=35, exceptions:
&gt;&gt; Wed May 23 07:15:57 KST 2018, 
RpcRetryingCaller{globalStartTime=1527027357808,
&gt;&gt; pause=100, retries=35}, org.apache.hadoop.hbase.RegionTooBusyException:
&gt;&gt; org.apache.hadoop.hbase.RegionTooBusyException: Above memstore limit,
&gt;&gt; regionName={region}, server={server}, memstoreSize=2600502128,
&gt;&gt; blockingMemStoreSize=2600468480
&gt;&gt;        at org.apache.hadoop.hbase.regionserver.HRegion.
&gt;&gt; checkResources(HRegion.java:3649)
&gt;&gt;        at org.apache.hadoop.hbase.regionserver.HRegion.
&gt;&gt; processRowsWithLocks(HRegion.java:6935)
&gt;&gt;        at org.apache.hadoop.hbase.regionserver.HRegion.
&gt;&gt; mutateRowsWithLocks(HRegion.java:6885)
&gt;&gt;        at org.apache.hadoop.hbase.coprocessor.MultiRowMutationEndpoint.
&gt;&gt; mutateRows(MultiRowMutationEndpoint.java:116)
&gt;&gt;        at org.apache.hadoop.hbase.protobuf.generated.
&gt;&gt; MultiRowMutationProtos$MultiRowMutationService.callMethod(
&gt;&gt; MultiRowMutationProtos.java:2053)
&gt;&gt;        at org.apache.hadoop.hbase.regionserver.HRegion.
&gt;&gt; execService(HRegion.java:7875)
&gt;&gt;        at org.apache.hadoop.hbase.regionserver.RSRpcServices.
&gt;&gt; execServiceOnRegion(RSRpcServices.java:2008)
&gt;&gt;
&gt;&gt;
&gt;&gt; Best regards,
&gt;&gt; Minwoo Kang
&gt;&gt;
&gt;&gt; ________________________________________
&gt;&gt; 보낸 사람: 张铎(Duo Zhang) <[email protected]>
&gt;&gt; 보낸 날짜: 2018년 5월 23일 수요일 09:22
&gt;&gt; 받는 사람: hbase-user
&gt;&gt; 제목: Re: can not write to HBase
&gt;&gt;
&gt;&gt; What is the exception? And the stacktrace?
&gt;&gt;
&gt;&gt; 2018-05-23 8:17 GMT+08:00 Kang Minwoo <[email protected]>:
&gt;&gt;
&gt;&gt;&gt; Hello, Users
&gt;&gt;&gt;
&gt;&gt;&gt; My HBase client does not work after print the following logs.
&gt;&gt;&gt;
&gt;&gt;&gt; Call exception, tries=23, retries=35, started=291277 ms ago,
&gt;&gt;&gt; cancelled=false, msg=row '{row}' on table '{table}' at 
region={region},
&gt;&gt;&gt; hostname={hostname}, seqNum=100353531
&gt;&gt;&gt;
&gt;&gt;&gt; There are no special logs in the Master and Region Servers.
&gt;&gt;&gt; Is it something wrong in the client?
&gt;&gt;&gt;
&gt;&gt;&gt; Best regards,
&gt;&gt;&gt; Minwoo Kang
&gt;&gt;&gt;
&gt;&gt;
</[email protected]></[email protected]></[email protected]></[email protected]></[email protected]></[email protected]></[email protected]>

Reply via email to