wrong client arg, should use executor-cores

tsdeng · tsdeng · commit 304826d87c8a · 2014-03-13T18:29:14.000-07:00
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
@@ -95,7 +95,7 @@ class ClientArguments(val args: Array[String], val sparkConf: SparkConf) {
           executorMemory = value
           args = tail
 
-        case ("--worker-cores" | "--executor-memory") :: IntParam(value) :: tail =>
+        case ("--worker-cores" | "--executor-cores") :: IntParam(value) :: tail =>
           if (args(0) == "--worker-cores") {
             println("--worker-cores is deprecated. Use --executor-cores instead.")
           }

Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,7 @@ class ClientArguments(val args: Array[String], val sparkConf: SparkConf) {`
`95`	`95`	`executorMemory = value`
`96`	`96`	`args = tail`
`97`	`97`
`98`		`- case ("--worker-cores" \| "--executor-memory") :: IntParam(value) :: tail =>`
	`98`	`+ case ("--worker-cores" \| "--executor-cores") :: IntParam(value) :: tail =>`
`99`	`99`	`if (args(0) == "--worker-cores") {`
`100`	`100`	`println("--worker-cores is deprecated. Use --executor-cores instead.")`
`101`	`101`	`}`