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 bf449afae695..3aae72fcc5dd 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 }