diff options
Diffstat (limited to 'exec/java-exec/src/main')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedListVector.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedListVector.java b/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedListVector.java index 00716cf0b..f903b0ca4 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedListVector.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedListVector.java @@ -324,8 +324,9 @@ public class RepeatedListVector extends AbstractContainerVector implements Repea for(int i = holder.start; i < holder.end; i++, newIndex++){ if(!vectorTransfer.copyValueSafe(i, newIndex)) return false; } - if(!this.to.offsets.getMutator().setSafe(to, newIndex)) return false; + if(!this.to.offsets.getMutator().setSafe(to + 1, newIndex)) return false; + this.to.lastSet++; return true; } |