diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-12-26 12:11:28 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-12-26 12:11:28 -0800 |
| commit | a97ad55c45f5903c85c7c15b27177316473f2c0c (patch) | |
| tree | bc8b1aadb9af2f90efd2bf4b42c0b44e56f46966 /core/src/main/scala/org/apache | |
| parent | 5938cfc153ac79148f288a1f228458a5df0c74dc (diff) | |
| download | spark-a97ad55c45f5903c85c7c15b27177316473f2c0c.tar.gz spark-a97ad55c45f5903c85c7c15b27177316473f2c0c.tar.bz2 spark-a97ad55c45f5903c85c7c15b27177316473f2c0c.zip | |
Removing accidental file
Diffstat (limited to 'core/src/main/scala/org/apache')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala | 3 | ||||
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala | 8 |
2 files changed, 1 insertions, 10 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala b/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala index d13e6519bb..402ad53f18 100644 --- a/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala @@ -136,8 +136,7 @@ private[spark] class DriverRunner( } /** Continue launching the supplied command until it exits zero or is killed. */ - def runCommandWithRetry(command: Seq[String], envVars: Seq[(String, String)], baseDir: File) - : Unit = { + def runCommandWithRetry(command: Seq[String], envVars: Seq[(String, String)], baseDir: File) { // Time to wait between submission retries. var waitSeconds = 1 var cleanExit = false diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala b/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala deleted file mode 100644 index 92fb0843f8..0000000000 --- a/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala +++ /dev/null @@ -1,8 +0,0 @@ -package org.apache.spark.deploy.worker - -object DriverWrapper { - def main(args: Array[String]) { - val c = Console.readChar() - println(s"Char: $c") - } -} |