diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java index e5d1dc438..ae0b733ff 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java @@ -41,9 +41,6 @@ import org.apache.drill.exec.vector.NullableVarCharVector; import org.apache.drill.exec.vector.NullableTimeStampVector; import org.apache.drill.exec.vector.NullableTimeVector; - -import org.apache.hadoop.fs.Path; - import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; @@ -522,7 +519,7 @@ public class LogRecordReader extends AbstractRecordReader { private void openFile() { InputStream in; try { - in = dfs.open(new Path(fileWork.getPath())); + in = dfs.open(fileWork.getPath()); } catch (Exception e) { throw UserException .dataReadError(e) |