Repository: hive
Updated Branches:
  refs/heads/master d52131d76 -> b93ce7825


HIVE-13720. Fix failing test - TestLlapTaskCommunicator. (Siddharth Seth, 
reviewed by Sergey Shelukhin)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b93ce782
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b93ce782
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b93ce782

Branch: refs/heads/master
Commit: b93ce7825ef095bfcf1bd3474f110773c35ea9ab
Parents: d52131d
Author: Siddharth Seth <ss...@apache.org>
Authored: Wed May 25 14:58:34 2016 -0700
Committer: Siddharth Seth <ss...@apache.org>
Committed: Wed May 25 14:58:34 2016 -0700

----------------------------------------------------------------------
 .../hadoop/hive/llap/tezplugins/TestLlapTaskCommunicator.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/b93ce782/llap-tez/src/test/org/apache/hadoop/hive/llap/tezplugins/TestLlapTaskCommunicator.java
----------------------------------------------------------------------
diff --git 
a/llap-tez/src/test/org/apache/hadoop/hive/llap/tezplugins/TestLlapTaskCommunicator.java
 
b/llap-tez/src/test/org/apache/hadoop/hive/llap/tezplugins/TestLlapTaskCommunicator.java
index 8e2d0ac..1901328 100644
--- 
a/llap-tez/src/test/org/apache/hadoop/hive/llap/tezplugins/TestLlapTaskCommunicator.java
+++ 
b/llap-tez/src/test/org/apache/hadoop/hive/llap/tezplugins/TestLlapTaskCommunicator.java
@@ -36,6 +36,7 @@ import java.util.concurrent.locks.ReentrantLock;
 
 import com.google.common.collect.Lists;
 import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hive.conf.HiveConf;
 import org.apache.hadoop.hive.llap.LlapNodeId;
 import org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos;
 import org.apache.hadoop.hive.llap.tez.LlapProtocolClientProxy;
@@ -273,11 +274,15 @@ public class TestLlapTaskCommunicator {
     final TezVertexID vertexId1 = TezVertexID.getInstance(dagid, 300);
     final TezVertexID vertexId2 = TezVertexID.getInstance(dagid, 301);
     final Configuration conf = new Configuration(false);
-    final UserPayload userPayload = TezUtils.createUserPayloadFromConf(conf);
+    final UserPayload userPayload;
 
     final LlapTaskCommunicatorForTest taskCommunicator;
 
     public LlapTaskCommunicatorWrapperForTest(LlapProtocolClientProxy 
llapProxy) throws Exception {
+
+      HiveConf.setVar(conf, HiveConf.ConfVars.LLAP_DAEMON_SERVICE_HOSTS, 
"fake-non-zk-cluster");
+      userPayload = TezUtils.createUserPayloadFromConf(conf);
+
       
doReturn(appAttemptId).when(taskCommunicatorContext).getApplicationAttemptId();
       doReturn(new 
Credentials()).when(taskCommunicatorContext).getAMCredentials();
       
doReturn(userPayload).when(taskCommunicatorContext).getInitialUserPayload();

Reply via email to