diff --git a/task/search_strategy_d.py b/task/search_strategy_d.py index 7a51530cc40b0131507797875c5325cbb3f9811e..5739f54b4509417ec905ed9987561829b7c04998 100644 --- a/task/search_strategy_d.py +++ b/task/search_strategy_d.py @@ -608,8 +608,7 @@ for t in range(0, task_days): on t1.cl_id=dev.device_id and t1.partition_date = dev.partition_date GROUP BY t1.query,active_type,device_os_type,channel )t6 - on t1.query=t6.query and t1.active_type=t6.active_type and t1.device_os_type = t6.device_os_type AND t1.channel = t6.channel - order by 1_pv desc,query""".format(last_30_day_str=last_30_day_str, today_str=today_str, + on t1.query=t6.query and t1.active_type=t6.active_type and t1.device_os_type = t6.device_os_type AND t1.channel = t6.channel""".format(last_30_day_str=last_30_day_str, today_str=today_str, yesterday_str=yesterday_str, one_week_age_str=one_week_age_str) device_df = spark.sql(sql) device_df.createOrReplaceTempView("data_table")