模型bug修复

be1db75b · 宋柯 · eb269e5e · be1db75b
Commit be1db75b authored Dec 10, 2021 by 宋柯
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

featureEngSk.py spark/featureEngSk.py +1 -1

No files found.
--- a/spark/featureEngSk.py
+++ b/spark/featureEngSk.py
@@ -981,7 +981,7 @@ if __name__ == '__main__':
            res.append((card_id, partition_date, label, partition_date_label_count_dcit.get(partition_date, 0)))
        return res

-    itemStatisticDF = itemStatisticDF.rdd.flatMap(splitPatitionDatasFlatMapFunc).toDF("card_id", "partition_date", "label", "label_count")
+    itemStatisticDF = itemStatisticDF.rdd.flatMap(splitPatitionDatasFlatMapFunc).toDF(["card_id", "partition_date", "label", "label_count"])
    itemStatisticDF.show(1000, False)
    sys.exit(1)
    clickDF = spark.sql(clickSql)