update

task/spark_test.py

@@ -94,8 +94,8 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 # huidu_device_id_df.createOrReplaceTempView("dev_view")
 sql_search_ctr = r"""
 SELECT query
-     , sum(all_search_uv) as all_search_uv --全部搜索uv
-     , sum(t3.all_search_pv) as all_search_pv --全部搜索pv
+     , all_search_uv as all_search_uv --全部搜索uv
+     , t3.all_search_pv as all_search_pv --全部搜索pv
 FROM (
          --搜索pvuv
          SELECT query