小编use*_*268的帖子

我试图将行批量放入HBase（0.90.0）中，大小约为1000（行），我有多个生产者线程将数据写入队列，还有一个消费者线程每隔几分钟就会唤醒一次，并写入所有在队列中以批处理形式发送到HBase。但是，我收到以下异常，并且我不确定这意味着什么。

Caused by: java.util.concurrent.RejectedExecutionException
    at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
    at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
    at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processBatch(HConnectionManager.java:1135)

任何帮助是极大的赞赏！