You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jd...@apache.org on 2016/05/06 17:25:06 UTC
[16/39] hive git commit: HIVE-13461: LLAP output format service not
actually registered in LLAP registry
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());
}