udpate

f97dd392 · litaolemo · f7f4d6af · f97dd392
Commit f97dd392 authored Sep 15, 2020 by litaolemo
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

ecommerce_income_report.py task/ecommerce_income_report.py +1 -1

No files found.
--- a/task/ecommerce_income_report.py
+++ b/task/ecommerce_income_report.py
@@ -215,7 +215,7 @@ JOIN
 )a2
 on a2.device_id = a1.cl_id
 AND a2.partition_date=a1.partition_date
-group by partition_date
+group by a1.partition_date
    """.format(start_date=yesterday_str,end_date=today_str)
    all_pv_df = spark.sql(pv_sql)
    all_pv_df.show(1)