diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/FileSystemPartitionDescriptor.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/planner/FileSystemPartitionDescriptor.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/FileSystemPartitionDescriptor.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/FileSystemPartitionDescriptor.java index fd2f850e8..7297c2706 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/FileSystemPartitionDescriptor.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/FileSystemPartitionDescriptor.java @@ -84,8 +84,8 @@ public class FileSystemPartitionDescriptor extends AbstractPartitionDescriptor { @Override public GroupScan createNewGroupScan(List<String> newFiles) throws IOException { - final FileSelection newFileSelection = new FileSelection(newFiles, getBaseTableLocation(), true); - final FileGroupScan newScan = ((FileGroupScan)scanRel.getGroupScan()).clone(newFileSelection); + final FileSelection newSelection = FileSelection.create(null, newFiles, getBaseTableLocation()); + final FileGroupScan newScan = ((FileGroupScan)scanRel.getGroupScan()).clone(newSelection); return newScan; } |