update

task/recommend_strategy_fix.py

@@ -136,7 +136,7 @@ for t in range(1, task_days):
     )t1 JOIN
             ( SELECT  partition_date,            
                     cl_id,
-                    count(card_id) as session_pv0
+                    count(distinct card_id) as session_pv0
             FROM
                      (SELECT partition_date,
                       cl_id,
@@ -190,7 +190,7 @@ for t in range(1, task_days):
                       app_session_id
             )a
             LATERAL VIEW explode (a.recommend_type) v as recommend_type
-            group by partition_date,cl_id,v.recommend_type having session_pv0 >= 4) t0
+            group by partition_date,cl_id having session_pv0 >= 4) t0
             on t1.device_id = t0.cl_id 
  LEFT JOIN
         (--精准曝光，卡片id和session_id去重