DRILL-1334: Make sure to copy operator id while cloning ParquetGroupScan
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/bea3a35a Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/bea3a35a Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/bea3a35a Branch: refs/heads/master Commit: bea3a35a249092fee24fcff7dfa2121fbb43e63e Parents: 437366f Author: Hanifi Gunes <hgu...@maprtech.com> Authored: Fri Aug 29 16:51:28 2014 -0700 Committer: Jacques Nadeau <jacq...@apache.org> Committed: Fri Aug 29 17:51:52 2014 -0700 ---------------------------------------------------------------------- .../apache/drill/exec/store/parquet/ParquetScanBatchCreator.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/bea3a35a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetScanBatchCreator.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetScanBatchCreator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetScanBatchCreator.java index 608c689..f77ac98 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetScanBatchCreator.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetScanBatchCreator.java @@ -80,8 +80,10 @@ public class ParquetScanBatchCreator implements BatchCreator<ParquetRowGroupScan newColums.add(column); } } + final int id = rowGroupScan.getOperatorId(); // Create the new row group scan with the new columns rowGroupScan = new ParquetRowGroupScan(rowGroupScan.getStorageEngine(), rowGroupScan.getRowGroupReadEntries(), newColums, rowGroupScan.getSelectionRoot()); + rowGroupScan.setOperatorId(id); } FileSystem fs = rowGroupScan.getStorageEngine().getFileSystem().getUnderlying();
