模型bug修复

spark/featureEngSk.py

@@ -1001,12 +1001,13 @@ if __name__ == '__main__':
         card_id, 
         label,
         partition_date, 
-        COALESCE(SUM(label_count) OVER(PARTITION BY card_id, label ORDER BY partition_date ROWS BETWEEN ${itemStatisticStartDays} PRECEDING AND 1 PRECEDING), 0) label_count_sum,
-        COALESCE(AVG(label_count) OVER(PARTITION BY card_id, label ORDER BY partition_date ROWS BETWEEN ${itemStatisticStartDays} PRECEDING AND 1 PRECEDING), 0) label_count_avg,
-        COALESCE(STDDEV(label_count) OVER(PARTITION BY card_id, label ORDER BY partition_date ROWS BETWEEN ${itemStatisticStartDays} PRECEDING AND 1 PRECEDING), 0) label_count_stddev
+        COALESCE(SUM(label_count) OVER(PARTITION BY card_id, label ORDER BY partition_date ROWS BETWEEN {itemStatisticStartDays} PRECEDING AND 1 PRECEDING), 0) label_count_sum,
+        COALESCE(AVG(label_count) OVER(PARTITION BY card_id, label ORDER BY partition_date ROWS BETWEEN {itemStatisticStartDays} PRECEDING AND 1 PRECEDING), 0) label_count_avg,
+        COALESCE(STDDEV(label_count) OVER(PARTITION BY card_id, label ORDER BY partition_date ROWS BETWEEN {itemStatisticStartDays} PRECEDING AND 1 PRECEDING), 0) label_count_stddev
     FROM
         itemStatisticDF
     """.format(itemStatisticStartDays = itemStatisticStartDays)
+    print(itemStatisticSql)
     spark.sql(itemStatisticSql).show(100, False)
     sys.exit(1)
     clickDF = spark.sql(clickSql)