DRILL-1334: Make sure to copy operator id while cloning ParquetGroupScan

1 files changed, 2 insertions, 0 deletions

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 608c6898b..f77ac9829 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();