Github user Vlad-Storona commented on a diff in the pull request: https://github.com/apache/drill/pull/989#discussion_r144286706 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/store/pcap/PcapRecordReader.java --- @@ -100,14 +104,14 @@ public void setup(final OperatorContext context, final OutputMutator output) thr this.output = output; this.buffer = new byte[100000]; - this.in = new FileInputStream(inputPath); + this.in = fs.open(pathToFile); this.decoder = new PacketDecoder(in); this.validBytes = in.read(buffer); this.projectedCols = getProjectedColsIfItNull(); setColumns(projectedColumns); } catch (IOException io) { throw UserException.dataReadError(io) - .addContext("File name:", inputPath) + .addContext("File name:", pathToFile.toString()) --- End diff -- Thanks, I will replace it.
---