apache#8 fix kerberos

hn5092 · Dec 27, 2018 · 77493ca · 77493ca
1 parent 45c3b35
commit 77493ca
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala
@@ -126,7 +126,9 @@ private[spark] class CoarseGrainedExecutorBackend(
 
     case UpdateDelegationTokens(tokenBytes) =>
       logInfo(s"Received tokens of ${tokenBytes.length} bytes")
-      SparkHadoopUtil.get.addDelegationTokens(tokenBytes, env.conf)
+      if (SparkEnv.get.executorId != SparkContext.DRIVER_IDENTIFIER) {
+        SparkHadoopUtil.get.addDelegationTokens(tokenBytes, env.conf)
+      }
   }
 
   override def onDisconnected(remoteAddress: RpcAddress): Unit = {