We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a63d747 commit 7fcec4aCopy full SHA for 7fcec4a
yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala
@@ -258,11 +258,9 @@ class YarnSparkHadoopUtil extends SparkHadoopUtil {
258
val confCreate = mirror.classLoader.
259
loadClass("org.apache.hadoop.hbase.HBaseConfiguration").
260
getMethod("create", classOf[Configuration])
261
-
262
val obtainToken = mirror.classLoader.
263
loadClass("org.apache.hadoop.hbase.security.token.TokenUtil").
264
getMethod("obtainToken", classOf[Configuration])
265
266
val hbaseConf = confCreate.invoke(null, conf).asInstanceOf[Configuration]
267
if ("kerberos" == hbaseConf.get("hbase.security.authentication")) {
268
logDebug("Attempting to fetch HBase security token.")
0 commit comments