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)
