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 void register() throws IOException { srv.addInternalEndpoint(getMngEndpoint()); srv.addInternalEndpoint(getShuffleEndpoint()); srv.addExternalEndpoint(getServicesEndpoint()); + srv.addInternalEndpoint(getOutputFormatEndpoint()); for (Map.Entry kv : this.conf) { if (kv.getKey().startsWith(HiveConf.PREFIX_LLAP) 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 void handleEvent(ReaderEvent event) { 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()); }