模型上线

spark/featureEngSk.py

@@ -787,7 +787,7 @@ def getPredictItemStatisticSql(start, end):
                     SELECT t1.partition_date, t1.card_id, 1 as label
                       FROM
                         (
-                            select cl_id, business_id as card_id
+                            select partition_date, cl_id, business_id as card_id
                             from online.bl_hdfs_maidian_updates
                             where action = 'page_view'
                             AND partition_date>='{startDay}' and partition_date<='{endDay}'
@@ -828,7 +828,7 @@ def getPredictItemStatisticSql(start, end):
                     SELECT t1.partition_date, t1.card_id, 0 as label
                     from
                         (	--新首页卡片曝光
-                            SELECT cl_id, card_id
+                            SELECT partition_date, cl_id, card_id
                             FROM online.ml_community_precise_exposure_detail
                             where partition_date>='{startDay}' and partition_date<='{endDay}'
                             and action in ('page_precise_exposure','home_choiceness_card_exposure')