update

task/spark_test.py

@@ -153,7 +153,7 @@ select count(1),avg(session_pv),avg(session_pv2) from (SELECT  partition_date,
                       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 ) having  session_pv2 >0
+            group by partition_date,card_content_type,cl_id,v.recommend_type having  session_pv2 >0) 
 """.format(start_date='20201018',end_date='20201025')
 
 print(sql_search_ctr)