DRILL-1371: HBase queries fail when hbase.scan.sizecalculator.enabled is set to false
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/2fa59368 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/2fa59368 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/2fa59368 Branch: refs/heads/master Commit: 2fa593685befd55f6e95997be5365fd76bb5873c Parents: 9ac177c Author: Aditya Kishore <[email protected]> Authored: Sun Sep 28 22:58:41 2014 -0700 Committer: Steven Phillips <[email protected]> Committed: Mon Sep 29 18:21:43 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/2fa59368/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java ---------------------------------------------------------------------- diff --git a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java index 1112de0..420fe77 100644 --- a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java +++ b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java @@ -293,7 +293,7 @@ public class HBaseGroupScan extends AbstractGroupScan implements DrillHBaseConst for (Entry<HRegionInfo, ServerName> regionEntry : regionsToAssignSet) { List<HBaseSubScanSpec> smallestList = minHeap.poll(); smallestList.add(regionInfoToSubScanSpec(regionEntry.getKey())); - if (smallestList.size() < minPerEndpointSlot) { + if (smallestList.size() < maxPerEndpointSlot) { minHeap.offer(smallestList); } }
