You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2014/10/14 06:57:58 UTC
svn commit: r1631615 -
/hive/trunk/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java
Author: vgumashta
Date: Tue Oct 14 04:57:58 2014
New Revision: 1631615
URL: http://svn.apache.org/r1631615
Log:
HIVE-8427: Hive Streaming : secure streaming hangs leading to time outs. (Roshan Naik reviewed by Vaibhav Gumashta)
Modified:
hive/trunk/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java
Modified: hive/trunk/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java
URL: http://svn.apache.org/viewvc/hive/trunk/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java?rev=1631615&r1=1631614&r2=1631615&view=diff
==============================================================================
--- hive/trunk/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java (original)
+++ hive/trunk/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java Tue Oct 14 04:57:58 2014
@@ -240,6 +240,7 @@ public class HiveEndPoint {
private final HiveEndPoint endPt;
private final UserGroupInformation ugi;
private final String username;
+ private final boolean secureMode;
/**
* @param endPoint end point to connect to
@@ -261,7 +262,8 @@ public class HiveEndPoint {
if (conf==null) {
conf = HiveEndPoint.createHiveConf(this.getClass(), endPoint.metaStoreUri);
}
- this.msClient = getMetaStoreClient(endPoint, conf);
+ this.secureMode = ugi==null ? false : ugi.hasKerberosCredentials();
+ this.msClient = getMetaStoreClient(endPoint, conf, secureMode);
if (createPart && !endPoint.partitionVals.isEmpty()) {
createPartitionIfNotExists(endPoint, msClient, conf);
}
@@ -425,13 +427,15 @@ public class HiveEndPoint {
return buff.toString();
}
- private static IMetaStoreClient getMetaStoreClient(HiveEndPoint endPoint, HiveConf conf)
+ private static IMetaStoreClient getMetaStoreClient(HiveEndPoint endPoint, HiveConf conf, boolean secureMode)
throws ConnectionError {
if (endPoint.metaStoreUri!= null) {
conf.setVar(HiveConf.ConfVars.METASTOREURIS, endPoint.metaStoreUri);
}
-
+ if(secureMode) {
+ conf.setBoolVar(HiveConf.ConfVars.METASTORE_USE_THRIFT_SASL,true);
+ }
try {
return new HiveMetaStoreClient(conf);
} catch (MetaException e) {