Skip to content

Commit af6d5f0

Browse files
Cleaning up files where changes weren't required.
1 parent f0f54cb commit af6d5f0

File tree

3 files changed

+1
-8
lines changed

3 files changed

+1
-8
lines changed

core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
package org.apache.spark.executor
1919

20-
import java.io.{ByteArrayInputStream, DataInputStream}
2120
import java.net.URL
2221
import java.nio.ByteBuffer
2322

@@ -27,8 +26,6 @@ import scala.concurrent.Await
2726
import akka.actor.{Actor, ActorSelection, Props}
2827
import akka.pattern.Patterns
2928
import akka.remote.{RemotingLifecycleEvent, DisassociatedEvent}
30-
import org.apache.hadoop.fs.{Path, FileSystem}
31-
import org.apache.hadoop.security.Credentials
3229

3330
import org.apache.spark.{Logging, SecurityManager, SparkConf, SparkEnv}
3431
import org.apache.spark.TaskState.TaskState
@@ -108,7 +105,6 @@ private[spark] class CoarseGrainedExecutorBackend(
108105
executor.stop()
109106
context.stop(self)
110107
context.system.shutdown()
111-
112108
}
113109

114110
override def statusUpdate(taskId: Long, state: TaskState, data: ByteBuffer) {

yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,6 @@ private[spark] class ApplicationMaster(
256256

257257
private def runDriver(securityMgr: SecurityManager): Unit = {
258258
addAmIpFilter()
259-
260259
userClassThread = startUserApplication()
261260

262261
// This a bit hacky, but we need to wait until the spark.driver.port property has

yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,8 @@
1818
package org.apache.spark.deploy.yarn
1919

2020
import java.io.File
21-
import java.net.{InetAddress, UnknownHostException, URI, URISyntaxException}
21+
import java.net.{InetAddress, UnknownHostException, URI}
2222
import java.nio.ByteBuffer
23-
import java.nio.file.Files
2423
import java.util.UUID
2524

2625
import scala.collection.JavaConversions._
@@ -33,7 +32,6 @@ import org.apache.hadoop.io.DataOutputBuffer
3332
import org.apache.hadoop.conf.Configuration
3433
import org.apache.hadoop.fs._
3534
import org.apache.hadoop.fs.permission.FsPermission
36-
import org.apache.hadoop.mapred.Master
3735
import org.apache.hadoop.mapreduce.MRJobConfig
3836
import org.apache.hadoop.security.{Credentials, UserGroupInformation}
3937
import org.apache.hadoop.util.StringUtils

0 commit comments

Comments
 (0)