[27845] Fixed the way Spark determines Hive’s security configuration (a…

…pache#119)
jamesrgrinter · Jun 23, 2017 · 52b06b9 · 52b06b9
1 parent 6917681
commit 52b06b9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...rs/yarn/src/main/scala/org/apache/spark/deploy/yarn/security/HiveCredentialProvider.scala b/...rs/yarn/src/main/scala/org/apache/spark/deploy/yarn/security/HiveCredentialProvider.scala
@@ -55,10 +55,10 @@ private[security] class HiveCredentialProvider extends ServiceCredentialProvider
     }
   }
 
-  override def credentialsRequired(hadoopConf: Configuration): Boolean = {
+  override def credentialsRequired(hadoopConf: Configuration): Boolean =
     UserGroupInformation.isSecurityEnabled &&
-      hiveConf(hadoopConf).getTrimmed("hive.metastore.uris", "").nonEmpty
-  }
+      hiveConf(hadoopConf).getTrimmed("hive.metastore.uris", "").nonEmpty &&
+      hiveConf(hadoopConf).getBoolean("hive.metastore.sasl.enabled", false)
 
   override def obtainCredentials(
       hadoopConf: Configuration,