hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Serega Sheypak <serega.shey...@gmail.com>
Subject Confusion with new 1.0 clint API
Date Mon, 08 Feb 2016 23:01:09 GMT
Hi, I'm confused with new HBase 1.0 API. API says that application should
manage connections (Previously HConnections) on their own. Nothing is
managed itnernally now.

Here is an example:
https://hbase.apache.org/xref/org/apache/hadoop/hbase/client/example/BufferedMutatorExample.html

It gives no clue about lifecycle :(
Right now I create single connection instance for servlet and
BufferedMutator per request.


//getConnection returns single instance, it doesn't return new connection
each time
def mutator = getConnection().getBufferedMutator(getBufferedMutatorParams())
users.each{ mutator.mutate(toPut(it))}
mutator.close() //exception is thrown here


And I get tons of exceptions thrown on "mutator.close()", what do I do
wrong?

WARNING: #905, the task was rejected by the pool. This is unexpected.
Server is node04.server.com, 60020,1447338864601
java.util.concurrent.RejectedExecutionException: Task
java.util.concurrent.FutureTask@5cff3b40 rejected from
java.util.concurrent.ThreadPoolExecutor@686c2853[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 1]
at
java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047)
at
java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
at
java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)
at
org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.sendMultiAction(AsyncProcess.java:956)
at
org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.access$000(AsyncProcess.java:574)
at
org.apache.hadoop.hbase.client.AsyncProcess.submitMultiActions(AsyncProcess.java:423)
at org.apache.hadoop.hbase.client.AsyncProcess.submit(AsyncProcess.java:403)
at org.apache.hadoop.hbase.client.AsyncProcess.submit(AsyncProcess.java:320)
at
org.apache.hadoop.hbase.client.BufferedMutatorImpl.backgroundFlushCommits(BufferedMutatorImpl.java:206)
at
org.apache.hadoop.hbase.client.BufferedMutatorImpl.close(BufferedMutatorImpl.java:158)
at org.apache.hadoop.hbase.client.BufferedMutator$close$0.call(Unknown
Source)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message