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 --- 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 @@ -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; }
