Commit 02f7ca6a authored by 张彦钊's avatar 张彦钊

change test fliw

parent 0d96fd95
......@@ -236,7 +236,7 @@ if __name__ == '__main__':
# TODO 删除下面的测试写入
df = spark.sql("select y,z from esmm_train_data limit 6000")
df.write.format("tfrecords").option("recordType", "Example").save(path="/strategy/esmm/tr/")
df.write.format("tfrecords").option("recordType", "Example").save(path="hdfs:///strategy/esmm/tr/")
print("done")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment