diff options
| author | Jey Kottalam <jey@cs.berkeley.edu> | 2013-07-24 12:41:40 -0700 |
|---|---|---|
| committer | Jey Kottalam <jey@cs.berkeley.edu> | 2013-08-15 16:50:37 -0700 |
| commit | 4f43fd791ab0e84693e2337358c6b880a1593e54 (patch) | |
| tree | e0ce8085b1d11cc9dc8086ef1314257f16f8ef6b /examples | |
| parent | 43ebcb84840dc9db61e5912d9a37707c065edc5a (diff) | |
| download | spark-4f43fd791ab0e84693e2337358c6b880a1593e54.tar.gz spark-4f43fd791ab0e84693e2337358c6b880a1593e54.tar.bz2 spark-4f43fd791ab0e84693e2337358c6b880a1593e54.zip | |
make SparkHadoopUtil a member of SparkEnv
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/spark/examples/SparkHdfsLR.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/examples/src/main/scala/spark/examples/SparkHdfsLR.scala b/examples/src/main/scala/spark/examples/SparkHdfsLR.scala index ef6e09a8e8..43c9115664 100644 --- a/examples/src/main/scala/spark/examples/SparkHdfsLR.scala +++ b/examples/src/main/scala/spark/examples/SparkHdfsLR.scala @@ -21,7 +21,6 @@ import java.util.Random import scala.math.exp import spark.util.Vector import spark._ -import spark.deploy.SparkHadoopUtil import spark.scheduler.InputFormatInfo /** @@ -52,7 +51,7 @@ object SparkHdfsLR { System.exit(1) } val inputPath = args(1) - val conf = SparkHadoopUtil.newConfiguration() + val conf = SparkEnv.get.hadoop.newConfiguration() val sc = new SparkContext(args(0), "SparkHdfsLR", System.getenv("SPARK_HOME"), Seq(System.getenv("SPARK_EXAMPLES_JAR")), Map(), InputFormatInfo.computePreferredLocations( |