修改rdd

eda/feededa/src/main/scala/com/gmei/Data2FFM.scala

@@ -60,10 +60,10 @@ object Data2FFM {
       ).na.drop()
       esmm_data.show(8)
       println(esmm_data.count())
-      esmm_data.createOrReplaceGlobalTempView("df")
-      val sql1 = "select * from df"
+      esmm_data.createOrReplaceTempView("a")
+      val sql1 = "select * from a"
       val df = sc.sql(sql1)
-
+      df.cache()
       val column_list = df.columns
 
       val max_stat_date = sc.sql(