diff options
author | tgravescs <tgraves_cs@yahoo.com> | 2013-10-29 20:12:45 -0500 |
---|---|---|
committer | tgravescs <tgraves_cs@yahoo.com> | 2013-10-29 20:12:45 -0500 |
commit | e5e0ebdb1190a256e51dbf1265c6957f0cd56a29 (patch) | |
tree | 06a6be31f164e83df8f51739b957b92b074470ff | |
parent | eeb5f64c67c98f7252aab0fe2c55b86976463c74 (diff) | |
download | spark-e5e0ebdb1190a256e51dbf1265c6957f0cd56a29.tar.gz spark-e5e0ebdb1190a256e51dbf1265c6957f0cd56a29.tar.bz2 spark-e5e0ebdb1190a256e51dbf1265c6957f0cd56a29.zip |
fix sparkhdfs lr test
-rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala b/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala index 646682878f..86dd9ca1b3 100644 --- a/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala +++ b/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala @@ -21,6 +21,7 @@ import java.util.Random import scala.math.exp import org.apache.spark.util.Vector import org.apache.spark._ +import org.apache.spark.deploy.SparkHadoopUtil import org.apache.spark.scheduler.InputFormatInfo /** @@ -51,7 +52,7 @@ object SparkHdfsLR { System.exit(1) } val inputPath = args(1) - val conf = SparkEnv.get.hadoop.newConfiguration() + val conf = SparkHadoopUtil.get.newConfiguration() val sc = new SparkContext(args(0), "SparkHdfsLR", System.getenv("SPARK_HOME"), Seq(System.getenv("SPARK_EXAMPLES_JAR")), Map(), InputFormatInfo.computePreferredLocations( |