DRILL-5234: External sort's spilling functionality does not work when the spilled columns contains a map type column closes #799
Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/25b213cd Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/25b213cd Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/25b213cd Branch: refs/heads/master Commit: 25b213cd39ec192bebd043770a8131c410699421 Parents: 163a0c4 Author: Paul Rogers <prog...@maprtech.com> Authored: Sat Mar 25 18:27:40 2017 -0700 Committer: Arina Ielchiieva <arina.yelchiy...@gmail.com> Committed: Fri Apr 7 15:25:15 2017 +0300 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/vector/complex/MapVector.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/drill/blob/25b213cd/exec/vector/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java ---------------------------------------------------------------------- diff --git a/exec/vector/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java b/exec/vector/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java index 8447893..af1ec8e 100644 --- a/exec/vector/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java +++ b/exec/vector/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java @@ -277,7 +277,10 @@ public class MapVector extends AbstractMapVector { bufOffset += child.getBufferLength(); } - assert bufOffset == buf.capacity(); + // We should have consumed all bytes written into the buffer + // during deserialization. + + assert bufOffset == buf.writerIndex(); } @Override
