diff options
author | Jey Kottalam <jey@cs.berkeley.edu> | 2013-07-24 13:07:27 -0700 |
---|---|---|
committer | Jey Kottalam <jey@cs.berkeley.edu> | 2013-08-15 16:50:37 -0700 |
commit | bd0bab47c9602462628b1d3c90d5eb5d889f4596 (patch) | |
tree | f6b77c9b351cc46e7a061ae46cb4ee8b9e7f3c22 /yarn/src | |
parent | 4f43fd791ab0e84693e2337358c6b880a1593e54 (diff) | |
download | spark-bd0bab47c9602462628b1d3c90d5eb5d889f4596.tar.gz spark-bd0bab47c9602462628b1d3c90d5eb5d889f4596.tar.bz2 spark-bd0bab47c9602462628b1d3c90d5eb5d889f4596.zip |
SparkEnv isn't available this early, and not needed anyway
Diffstat (limited to 'yarn/src')
-rw-r--r-- | yarn/src/main/scala/spark/deploy/SparkHadoopUtil.scala | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/yarn/src/main/scala/spark/deploy/SparkHadoopUtil.scala b/yarn/src/main/scala/spark/deploy/SparkHadoopUtil.scala index 6122fdced0..a812bcf867 100644 --- a/yarn/src/main/scala/spark/deploy/SparkHadoopUtil.scala +++ b/yarn/src/main/scala/spark/deploy/SparkHadoopUtil.scala @@ -32,22 +32,6 @@ object SparkHadoopUtil { val yarnConf = newConfiguration() - def getUserNameFromEnvironment(): String = { - // defaulting to env if -D is not present ... - val retval = System.getProperty(Environment.USER.name, System.getenv(Environment.USER.name)) - - // If nothing found, default to user we are running as - if (retval == null) System.getProperty("user.name") else retval - } - - def runAsUser(func: (Product) => Unit, args: Product) { - runAsUser(func, args, getUserNameFromEnvironment()) - } - - def runAsUser(func: (Product) => Unit, args: Product, user: String) { - func(args) - } - // Note that all params which start with SPARK are propagated all the way through, so if in yarn mode, this MUST be set to true. def isYarnMode(): Boolean = { val yarnMode = System.getProperty("SPARK_YARN_MODE", System.getenv("SPARK_YARN_MODE")) |