aboutsummaryrefslogtreecommitdiff
path: root/yarn
diff options
context:
space:
mode:
authorXuTingjun <1039320815@qq.com>2014-08-22 10:45:00 -0500
committerThomas Graves <tgraves@apache.org>2014-08-22 10:45:00 -0500
commit220c2d7699a522c50d26cd6fdd94f4635823e408 (patch)
tree6d375ec753586bb590a229d813a87192531fa28f /yarn
parent050f8d01e47b9b67b02ce50d83fb7b4e528b7204 (diff)
downloadspark-220c2d7699a522c50d26cd6fdd94f4635823e408.tar.gz
spark-220c2d7699a522c50d26cd6fdd94f4635823e408.tar.bz2
spark-220c2d7699a522c50d26cd6fdd94f4635823e408.zip
[SPARK-2742][yarn] delete useless variables
Author: XuTingjun <1039320815@qq.com> Closes #1614 from XuTingjun/yarn-bug and squashes the following commits: f07096e [XuTingjun] Update ClientArguments.scala
Diffstat (limited to 'yarn')
-rw-r--r--yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala5
1 files changed, 1 insertions, 4 deletions
diff --git a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
index 62f9b3cf5a..afa4fd4c69 100644
--- a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
+++ b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
@@ -39,7 +39,6 @@ class ClientArguments(val args: Array[String], val sparkConf: SparkConf) {
var amMemory: Int = 512 // MB
var amClass: String = "org.apache.spark.deploy.yarn.ApplicationMaster"
var appName: String = "Spark"
- var inputFormatInfo: List[InputFormatInfo] = null
var priority = 0
parseArgs(args.toList)
@@ -58,8 +57,7 @@ class ClientArguments(val args: Array[String], val sparkConf: SparkConf) {
private def parseArgs(inputArgs: List[String]): Unit = {
val userArgsBuffer: ArrayBuffer[String] = new ArrayBuffer[String]()
- val inputFormatMap: HashMap[String, InputFormatInfo] = new HashMap[String, InputFormatInfo]()
-
+
var args = inputArgs
while (!args.isEmpty) {
@@ -145,7 +143,6 @@ class ClientArguments(val args: Array[String], val sparkConf: SparkConf) {
}
userArgs = userArgsBuffer.readOnly
- inputFormatInfo = inputFormatMap.values.toList
}