Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill >> mail # dev >> [11/17] git commit: DRILL-358: Fix bug in stream aggregate with sv2


Copy link to this message
-
[11/17] git commit: DRILL-358: Fix bug in stream aggregate with sv2
DRILL-358: Fix bug in stream aggregate with sv2
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/d9095509
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/d9095509
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/d9095509

Branch: refs/heads/master
Commit: d9095509d8624683b25fa1ca6a0c2a8c97faf2fe
Parents: fefda25
Author: Steven Phillips <[EMAIL PROTECTED]>
Authored: Wed Jan 29 16:47:51 2014 -0800
Committer: Jacques Nadeau <[EMAIL PROTECTED]>
Committed: Sat Apr 19 21:07:28 2014 -0700

 .../drill/exec/physical/impl/aggregate/StreamingAggBatch.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d9095509/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java
index 5eff355..c942dc6 100644
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/aggregate/StreamingAggBatch.java
@@ -304,7 +304,7 @@ public class StreamingAggBatch extends AbstractRecordBatch<StreamingAggregate> {
     case TWO_BYTE: {
       JVar var = g.declareClassField("sv2_", g.getModel()._ref(SelectionVector2.class));
       g.getBlock("setupInterior").assign(var, JExpr.direct("incoming").invoke("getSelectionVector2"));
-      g.getBlock("getVectorIndex")._return(var.invoke("get").arg(JExpr.direct("recordIndex")));;
+      g.getBlock("getVectorIndex")._return(var.invoke("getIndex").arg(JExpr.direct("recordIndex")));;
       return;
     }