aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java
diff options
context:
space:
mode:
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java6
1 files changed, 4 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java
index 766813006..1d7226ad1 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/avro/AvroRecordReader.java
@@ -403,9 +403,11 @@ public class AvroRecordReader extends AbstractRecordReader {
public String toString() {
long currentPosition = -1L;
try {
- currentPosition = reader.tell();
+ if (reader != null) {
+ currentPosition = reader.tell();
+ }
} catch (IOException e) {
- logger.trace("Unable to obtain reader position: " + e.getMessage());
+ logger.trace("Unable to obtain reader position.", e);
}
return "AvroRecordReader[File=" + hadoop
+ ", Position=" + currentPosition