diff options
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.java | 4 |
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>()); |