update

0f2ee04f · litaolemo · 10db9cdb · 0f2ee04f
Commit 0f2ee04f authored Nov 19, 2020 by litaolemo
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

spark_test.py task/spark_test.py +1 -1

No files found.
--- a/task/spark_test.py
+++ b/task/spark_test.py
@@ -204,7 +204,7 @@ sql_search_ctr = r"""
            LATERAL VIEW explode (a.recommend_type) v as recommend_type
            group by partition_date,cl_id having  session_pv0 >= 4

-""".format(start_date='20201017',end_date='20201116')
+""".format(start_date='20201017',end_date='20201116',partition_day='20201116')

 print(sql_search_ctr)
 search_ctr_df = spark.sql(sql_search_ctr)