hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jd...@apache.org
Subject [16/39] hive git commit: HIVE-13461: LLAP output format service not actually registered in LLAP registry
Date Fri, 06 May 2016 17:25:06 GMT
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 <jdere@hortonworks.com>
Authored: Fri Apr 8 11:46:03 2016 -0700
Committer: Jason Dere <jdere@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());
     }


Mime
View raw message