HIVE-13461: LLAP output format service not actually registered in LLAP registry
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8f6b28a3 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8f6b28a3 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8f6b28a3 Branch: refs/heads/master Commit: 8f6b28a38d495043793585593c4fb7152bb8a112 Parents: 79c1c69 Author: Jason Dere <jd...@hortonworks.com> Authored: Fri Apr 8 11:46:03 2016 -0700 Committer: Jason Dere <jd...@hortonworks.com> Committed: Fri Apr 8 11:46:03 2016 -0700 ---------------------------------------------------------------------- .../hadoop/hive/llap/registry/impl/LlapZookeeperRegistryImpl.java | 1 + ql/src/java/org/apache/hadoop/hive/llap/LlapRecordReader.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/8f6b28a3/llap-client/src/java/org/apache/hadoop/hive/llap/registry/impl/LlapZookeeperRegistryImpl.java ---------------------------------------------------------------------- diff --git a/llap-client/src/java/org/apache/hadoop/hive/llap/registry/impl/LlapZookeeperRegistryImpl.java b/llap-client/src/java/org/apache/hadoop/hive/llap/registry/impl/LlapZookeeperRegistryImpl.java index bc99a3c..e49c047 100644 --- a/llap-client/src/java/org/apache/hadoop/hive/llap/registry/impl/LlapZookeeperRegistryImpl.java +++ b/llap-client/src/java/org/apache/hadoop/hive/llap/registry/impl/LlapZookeeperRegistryImpl.java @@ -259,6 +259,7 @@ public class LlapZookeeperRegistryImpl implements ServiceRegistry { srv.addInternalEndpoint(getMngEndpoint()); srv.addInternalEndpoint(getShuffleEndpoint()); srv.addExternalEndpoint(getServicesEndpoint()); + srv.addInternalEndpoint(getOutputFormatEndpoint()); for (Map.Entry<String, String> kv : this.conf) { if (kv.getKey().startsWith(HiveConf.PREFIX_LLAP) http://git-wip-us.apache.org/repos/asf/hive/blob/8f6b28a3/ql/src/java/org/apache/hadoop/hive/llap/LlapRecordReader.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/llap/LlapRecordReader.java b/ql/src/java/org/apache/hadoop/hive/llap/LlapRecordReader.java index 30ed9cf..64e5e69 100644 --- a/ql/src/java/org/apache/hadoop/hive/llap/LlapRecordReader.java +++ b/ql/src/java/org/apache/hadoop/hive/llap/LlapRecordReader.java @@ -181,6 +181,7 @@ public class LlapRecordReader<V extends WritableComparable> implements RecordRea LOG.debug("Interrupting reader thread due to reader event with error " + event.getMessage()); } getReaderThread().interrupt(); + break; default: throw new RuntimeException("Unhandled ReaderEvent type " + event.getEventType() + " with message " + event.getMessage()); }
