[ https://issues.apache.org/jira/browse/HBASE-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ChiaPing Tsai updated HBASE-17376: ---------------------------------- Attachment: HBASE.17376.v0.patch > 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 > Attachments: HBASE.17376.v0.patch > > > 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)