diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java index 2a4b4fb48..08ed4fd09 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java @@ -99,10 +99,10 @@ public class ImageRecordReader extends AbstractRecordReader { private DrillBuf managedBuffer; private boolean finish; - public ImageRecordReader(FragmentContext context, DrillFileSystem fs, String inputPath, + public ImageRecordReader(FragmentContext context, DrillFileSystem fs, Path inputPath, boolean fileSystemMetadata, boolean descriptive, String timeZone) { this.fs = fs; - hadoopPath = fs.makeQualified(new Path(inputPath)); + hadoopPath = fs.makeQualified(inputPath); this.fileSystemMetadata = fileSystemMetadata; this.descriptive = descriptive; this.timeZone = (timeZone != null) ? TimeZone.getTimeZone(timeZone) : TimeZone.getDefault(); |