update

task/spark_test.py

@@ -93,12 +93,12 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 # huidu_device_id_df = spark.sql(huidu_device_id_sql)
 # huidu_device_id_df.createOrReplaceTempView("dev_view")
 sql_search_ctr = r"""
-select count(1),avg(session_pv) from (SELECT  partition_date,
-                    card_content_type,
+select count(1),avg(session_pv),avg(session_pv2) from (SELECT  partition_date,
                     cl_id,
                     v.recommend_type,
                     count(distinct app_session_id) as session_pv ,
-                     count(app_session_id) as session_pv1
+                     count(app_session_id) as session_pv1,
+                     count(card_id) as session_pv2
             FROM
             (
                SELECT partition_date,