From dfb4c697bcfcbbe7e0959894244e71f38edd79f9 Mon Sep 17 00:00:00 2001 From: "Y.CORP.YAHOO.COM\\tgraves" Date: Mon, 26 Aug 2013 13:57:01 -0500 Subject: Throw exception if the yarn local dirs isn't set --- yarn/src/main/scala/spark/deploy/yarn/ApplicationMaster.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'yarn') diff --git a/yarn/src/main/scala/spark/deploy/yarn/ApplicationMaster.scala b/yarn/src/main/scala/spark/deploy/yarn/ApplicationMaster.scala index cda3c21c58..33e6293a6b 100644 --- a/yarn/src/main/scala/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/src/main/scala/spark/deploy/yarn/ApplicationMaster.scala @@ -102,7 +102,11 @@ class ApplicationMaster(args: ApplicationMasterArguments, conf: Configuration) e val yarnLocalSysDirs = Option(System.getenv("YARN_LOCAL_DIRS")) yarnLocalSysDirs match { case Some(s) => localDirs = s - case None => if (localDirs == null) localDirs = "" + case None => { + if ((localDirs == null) || (localDirs.isEmpty())) { + throw new Exception("Yarn Local dirs can't be empty") + } + } } return localDirs } -- cgit v1.2.3