diff options
| author | Steven Phillips <smp@apache.org> | 2015-07-08 17:35:09 -0700 |
|---|---|---|
| committer | Steven Phillips <smp@apache.org> | 2015-07-28 18:13:22 -0700 |
| commit | 496f14669b485d5cd51b1f2a742b90de794190a9 (patch) | |
| tree | ce4fc8534dd02c50364d13fb2f332df019b2308c /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter | |
| parent | 5e33a286a3dad4b44c00dbae7fa40be678742b14 (diff) | |
DRILL-3353: Fix dropping nested fields
Use the SchemaChangeCallBack in more places to track schema changes
Reset the ephemeral transfer pair when making a new transfer pair for Map or RepeatedMap
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java index 5eee9dfe5..c1d78c374 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java @@ -193,7 +193,7 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ cg.addExpr(new ReturnValueExpression(expr)); for (VectorWrapper<?> v : incoming) { - TransferPair pair = v.getValueVector().makeTransferPair(container.addOrGet(v.getField())); + TransferPair pair = v.getValueVector().makeTransferPair(container.addOrGet(v.getField(), callBack)); transfers.add(pair); } |