update

task/recommend_strategy_fix.py

@@ -195,7 +195,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,card_content_type,cl_id,v.recommend_type,card_id having session_pv >= 4
+            group by partition_date,card_content_type,cl_id,v.recommend_type,card_id
           )t2  
         on t1.device_id=t2.cl_id and t1.partition_date=t2.partition_date 
         LEFT JOIN
@@ -722,7 +722,7 @@ for t in range(1, task_days):
         on t2.partition_date=dev.partition_date and t2.cl_id=dev.device_id
     WHERE spam_pv.device_id IS NULL
       and dev.device_id is null
-    GROUP BY t1.partition_date,t1.device_os_type,t1.active_type,t2.card_content_type,t2.recommend_type
+    GROUP BY t1.partition_date,t1.device_os_type,t1.active_type,t2.card_content_type,t2.recommend_type  having t2.session_pv >= 4
     order by day_id,device_os_type,active_type,card_content_type,recommend_type
     """.format(partition_day=today_str)
     ctr_df = spark.sql(ctr_sql)