diff --git a/task/ecommerce_income_report.py b/task/ecommerce_income_report.py index b676198886a2e5f0e4b05758e5a21dfbcbb58dbc..07b5d0a8e0dc459fa27d3d4c526b6f8b439cf8b6 100644 --- a/task/ecommerce_income_report.py +++ b/task/ecommerce_income_report.py @@ -355,7 +355,7 @@ group by partition_day bus_detail.referrer_search_welfare_pv / quanzhong_dau_view.quanzhong_dau as pv_div_quanzhong_dau, (cpc_income.cpt_click_num + cpc_income.cpc_click_num) / bus_detail.referrer_search_welfare_pv as ad_flow_rat, cpc_income.cpc_proportion_expend_amount/cpc_budget.budget as budget_consumption_rate, - cpc_income.cpc_proportion_expend_recharge_amount/cpc_income.cpc_click_num as cpc_item_pricing + cpc_income.cpc_proportion_expend_recharge_amount/cpc_income.cpc_click_num as cpc_item_pricing, cpc_income.tol_proportion_expend_amount as tol_proportion_expend_amount """ out_df = spark.sql(out_put_sql)