diff options
| author | Serhii-Harnyk <serhii.harnyk@gmail.com> | 2016-12-27 16:20:37 +0000 |
|---|---|---|
| committer | Jinfeng Ni <jni@apache.org> | 2017-01-23 17:08:58 -0800 |
| commit | 2af709f43d01f341b2a52c6473ea49d6761fdc61 (patch) | |
| tree | 6286a2501ff58f083dcd7b4d8846b46e805c8aa0 /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java | |
| parent | 8217697647e7ed10c52cfa91b860730302a339e8 (diff) | |
DRILL-5164: Equi-join query results in CompileException when inputs have large number of columns.
close apache/drill#711
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java index 23741b07f..f1f81fbb0 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java @@ -439,7 +439,7 @@ public class HashJoinBatch extends AbstractRecordBatch<HashJoinPOP> { .arg(buildIndex.band(JExpr.lit((int) Character.MAX_VALUE))) .arg(outIndex) .arg(inVV.component(buildIndex.shrz(JExpr.lit(16))))); - + g.rotateBlock(); fieldId++; } } @@ -475,7 +475,7 @@ public class HashJoinBatch extends AbstractRecordBatch<HashJoinPOP> { final JVar outVV = g.declareVectorValueSetupAndMember("outgoing", new TypedFieldId(outputType, false, outputFieldId)); g.getEvalBlock().add(outVV.invoke("copyFromSafe").arg(probeIndex).arg(outIndex).arg(inVV)); - + g.rotateBlock(); fieldId++; outputFieldId++; } |