From d6bfba3d7b9236a02a7e91233f8e512bea761af0 Mon Sep 17 00:00:00 2001 From: "pankaj.arora" Date: Sat, 31 May 2014 16:41:05 +0530 Subject: [PATCH] [SPARK-1979] Added Error Handling if user passes application params with --arg --- .../scala/org/apache/spark/deploy/SparkSubmitArguments.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala index bf449afae695f..3aae72fcc5dd2 100644 --- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala +++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala @@ -319,6 +319,10 @@ private[spark] class SparkSubmitArguments(args: Seq[String]) { parse(tail) } } else { + if (!value.isEmpty && value.equals("--arg")) { + val errMessage = "User application arguments are inferred directly, --arg not supported" + SparkSubmit.printErrorAndExit(errMessage) + } if (!value.isEmpty) { childArgs += value }