Commit 87a8b395 authored by 郭羽's avatar 郭羽

service model 优化

parent e776b8b5
...@@ -757,8 +757,7 @@ if __name__ == '__main__': ...@@ -757,8 +757,7 @@ if __name__ == '__main__':
print("train_data start:{} end:{}".format(startDay,endDay)) print("train_data start:{} end:{}".format(startDay,endDay))
conf = SparkConf().setAppName('featureEngineering').setMaster('local') spark = get_spark("service_feature_csv_export")
spark = SparkSession.builder.config(conf=conf).getOrCreate()
spark.sparkContext.setLogLevel("ERROR") spark.sparkContext.setLogLevel("ERROR")
# 行为数据 # 行为数据
clickSql = getClickSql(startDay,endDay) clickSql = getClickSql(startDay,endDay)
......
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