aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java
diff options
context:
space:
mode:
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java
index 50d7ee8f9..10d90d4b7 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroDrillTable.java
@@ -54,8 +54,8 @@ public class AvroDrillTable extends DrillTable {
SchemaConfig schemaConfig,
FormatSelection selection) {
super(storageEngineName, plugin, schemaConfig.getUserName(), selection);
- List<String> asFiles = selection.getAsFiles();
- Path path = new Path(asFiles.get(0));
+ List<Path> asFiles = selection.getAsFiles();
+ Path path = asFiles.get(0);
this.schemaConfig = schemaConfig;
try {
reader = new DataFileReader<>(new FsInput(path, plugin.getFsConf()), new GenericDatumReader<GenericContainer>());