diff options
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.java | 6 |
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 |