fixed old dep

ArtRand · ArtRand · commit e6a73573c927 · 2017-07-21T11:11:21.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala
@@ -31,7 +31,6 @@ import org.apache.hadoop.security.{Credentials, UserGroupInformation}
 import org.apache.spark._
 import org.apache.spark.TaskState.TaskState
 import org.apache.spark.deploy.SparkHadoopUtil
-import org.apache.spark.deploy.security.CredentialsSerializer
 import org.apache.spark.deploy.worker.WorkerWatcher
 import org.apache.spark.internal.Logging
 import org.apache.spark.rpc._
@@ -223,7 +222,7 @@ private[spark] object CoarseGrainedExecutorBackend extends Logging {
       }
 
       cfg.hadoopDelegationCreds.foreach { hadoopCreds =>
-        val creds = new CredentialsSerializer().deserialize(hadoopCreds)
+        val creds = SparkHadoopUtil.get.deserialize(hadoopCreds)
         SparkHadoopUtil.get.addCurrentUserCredentials(creds)
       }
 

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,6 @@ import org.apache.hadoop.security.{Credentials, UserGroupInformation}`
`31`	`31`	`import org.apache.spark._`
`32`	`32`	`import org.apache.spark.TaskState.TaskState`
`33`	`33`	`import org.apache.spark.deploy.SparkHadoopUtil`
`34`		`-import org.apache.spark.deploy.security.CredentialsSerializer`
`35`	`34`	`import org.apache.spark.deploy.worker.WorkerWatcher`
`36`	`35`	`import org.apache.spark.internal.Logging`
`37`	`36`	`import org.apache.spark.rpc._`
`@@ -223,7 +222,7 @@ private[spark] object CoarseGrainedExecutorBackend extends Logging {`
`223`	`222`	`}`
`224`	`223`
`225`	`224`	`cfg.hadoopDelegationCreds.foreach { hadoopCreds =>`
`226`		`- val creds = new CredentialsSerializer().deserialize(hadoopCreds)`
	`225`	`+ val creds = SparkHadoopUtil.get.deserialize(hadoopCreds)`
`227`	`226`	`SparkHadoopUtil.get.addCurrentUserCredentials(creds)`
`228`	`227`	`}`
`229`	`228`