diff options
| author | Bohdan Kazydub <bohdan.kazydub@gmail.com> | 2018-10-16 17:11:36 +0300 |
|---|---|---|
| committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2018-10-19 14:34:01 +0300 |
| commit | 91962d3dd38119ad04fa6b646a4980fd77e828d8 (patch) | |
| tree | 2e97fb109d4412f58f92713eba05ffc470d1a11c /contrib | |
| parent | f5bdbf344bfbd069fd3f1143b23624457ace19a9 (diff) | |
DRILL-6793: FragmentExecutor cannot send its final state for the case when RootExec root wasn't initialized
closes #1506
Diffstat (limited to 'contrib')
2 files changed, 2 insertions, 2 deletions
diff --git a/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/json/MaprDBJsonRecordReader.java b/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/json/MaprDBJsonRecordReader.java index b68f57403..628a98621 100644 --- a/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/json/MaprDBJsonRecordReader.java +++ b/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/mapr/db/json/MaprDBJsonRecordReader.java @@ -531,7 +531,7 @@ public class MaprDBJsonRecordReader extends AbstractRecordReader { @Override public String toString() { StringBuilder sb = new StringBuilder("MaprDBJsonRecordReader[Table=") - .append(table.getPath()); + .append(table != null ? table.getPath() : null); if (reader != null) { sb.append(", Document ID=") .append(IdCodec.asString(reader.getId())); diff --git a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java index 5ed6c3bb7..cc774d975 100644 --- a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java +++ b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java @@ -429,7 +429,7 @@ public abstract class HiveAbstractReader extends AbstractRecordReader { position = reader.getPos(); } } catch (IOException e) { - logger.trace("Unable to obtain reader position: " + e.getMessage()); + logger.trace("Unable to obtain reader position.", e); } return getClass().getSimpleName() + "[Database=" + table.getDbName() + ", Table=" + table.getTableName() |