repair bug

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

@@ -59,10 +59,10 @@ object app_list {
       //获取策略命中用户device_id
       val app_list = sc.sql(
         s"""
-           |select cl_id as device_id,params['installed_app_info'] as app_list
+           |select distinct(cl_id) as device_id,params['installed_app_info'] as app_list
            |from online.tl_hdfs_maidian_view
            |where action="user_installed_all_app_info"
-           |and partition_date = '20181118'
+           |and partition_date <= '20181118'
          """.stripMargin
       )
       //app_list.show()
@@ -71,6 +71,9 @@ object app_list {
         .filter(x => x._2.contains("新氧美容")).map(x => x._1).collect().toList
       val a = rdd.slice(0,2)
       println(a)
+      val len = rdd.length
+      println(len)
+