ChiaPing Tsai created HBASE-17376: ------------------------------------- Summary: ClientAsyncPrefetchScanner fails due to too many rows Key: HBASE-17376 URL: https://issues.apache.org/jira/browse/HBASE-17376 Project: HBase Issue Type: Bug Reporter: ChiaPing Tsai
ClientAsyncPrefetchScanner uses a fixed capacity LinkedBlockingQueue, so it may throw “queue full”. For example, scan with infinite caching or extra data from observer. {noformat} @Override protected void initCache() { // concurrent cache cacheCapacity = calcCacheCapacity(); cache = new LinkedBlockingQueue<Result>(cacheCapacity); cacheSizeInBytes = new AtomicLong(0); exceptionsQueue = new ConcurrentLinkedQueue<Exception>(); prefetchRunnable = new PrefetchRunnable(); prefetchRunning = new AtomicBoolean(false); closingThreadId = new AtomicLong(NO_THREAD); } {noformat} -- This message was sent by Atlassian JIRA (v6.3.4#6332)