diff options
Diffstat (limited to 'contrib/format-syslog/src/main/java')
-rw-r--r-- | contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java b/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java index a198e3444..4b2831c2d 100644 --- a/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java +++ b/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java @@ -32,7 +32,6 @@ import org.apache.drill.exec.store.dfs.DrillFileSystem; import org.apache.drill.exec.store.dfs.easy.FileWork; import org.apache.drill.exec.vector.complex.impl.VectorContainerWriter; import org.apache.drill.exec.vector.complex.writer.BaseWriter; -import org.apache.hadoop.fs.Path; import org.realityforge.jsyslog.message.StructuredDataParameter; import org.realityforge.jsyslog.message.SyslogMessage; @@ -95,7 +94,7 @@ public class SyslogRecordReader extends AbstractRecordReader { private void openFile() { InputStream in; try { - in = fileSystem.open(new Path(fileWork.getPath())); + in = fileSystem.open(fileWork.getPath()); } catch (Exception e) { throw UserException .dataReadError(e) |