update

task/recommend_strategy_fix.py

@@ -115,6 +115,10 @@ for t in range(1, task_days):
         NVL(sum(post_click_pv),0) as post_click_pv
     
     FROM
+    ( SELECT  partition_date,            
+                    cl_id,
+                    count(card_id) as session_pv0
+            FROM
     (
                SELECT partition_date,
                       cl_id,
@@ -170,7 +174,6 @@ for t in range(1, task_days):
             LATERAL VIEW explode (a.recommend_type) v as recommend_type
             group by partition_date,cl_id,v.recommend_type having session_pv0 >= 4) t0
 left join
-
     (
         SELECT partition_date
              ,device_os_type