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 /examples | |
| parent | eeb5f64c67c98f7252aab0fe2c55b86976463c74 (diff) | |
| download | spark-e5e0ebdb1190a256e51dbf1265c6957f0cd56a29.tar.gz spark-e5e0ebdb1190a256e51dbf1265c6957f0cd56a29.tar.bz2 spark-e5e0ebdb1190a256e51dbf1265c6957f0cd56a29.zip | |
fix sparkhdfs lr test
Diffstat (limited to 'examples')
| -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( |