修改错误代码

linwt · Sep 14, 2018 · d5c9a98 · d5c9a98
1 parent 0ab53dc
commit d5c9a98
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/Imooc_SparkSQL/src/main/scala/main/TopNYarn.scala b/Imooc_SparkSQL/src/main/scala/main/TopNYarn.scala
@@ -18,7 +18,7 @@ object TopNYarn {
     val spark = SparkSession.builder()
       .config("spark.sql.sources.partitionColumnTypeInference.enabled", false)
       .getOrCreate()
-    val df = spark.read.format("parquet").load("inputpath")
+    val df = spark.read.format("parquet").load(inputpath)
     df.printSchema()
     df.show(false)