Fix broken Kubernetes code

ash211 · ash211 · commit 90b58ac18926 · 2017-08-29T23:18:34.000-07:00
The hadoopDelegationCreds is available from super class CoarseGrainedSchedulerBackend
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/kubernetes/KubernetesClusterSchedulerBackend.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/kubernetes/KubernetesClusterSchedulerBackend.scala
@@ -768,7 +768,8 @@ private[spark] class KubernetesClusterSchedulerBackend(
 
                 val reply = SparkAppConfig(
                   resolvedProperties,
-                  SparkEnv.get.securityManager.getIOEncryptionKey())
+                  SparkEnv.get.securityManager.getIOEncryptionKey(),
+                  hadoopDelegationCreds)
                 context.reply(reply)
               }
           }

Original file line number	Diff line number	Diff line change
`@@ -768,7 +768,8 @@ private[spark] class KubernetesClusterSchedulerBackend(`
`768`	`768`
`769`	`769`	`val reply = SparkAppConfig(`
`770`	`770`	`resolvedProperties,`
`771`		`- SparkEnv.get.securityManager.getIOEncryptionKey())`
	`771`	`+ SparkEnv.get.securityManager.getIOEncryptionKey(),`
	`772`	`+ hadoopDelegationCreds)`
`772`	`773`	`context.reply(reply)`
`773`	`774`	`}`
`774`	`775`	`}`