aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/log/LogRecordReader.java
diff options
context:
space:
mode:
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.java5
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)