降配

task/home_feed_recommend_strategy_d.py

@@ -210,6 +210,8 @@ pandas_df.fillna(0,inplace=True)
 pandas_df['卡片ctr'] = pandas_df['卡片点击pv']/pandas_df['卡片曝光pv']
 print(pandas_df)
 
+spark.stop()
+
 for row in pandas_df.iterrows():
     partition_date = row[1]['日期']
     device_os_type = row[1]['设备类型']
@@ -238,7 +240,7 @@ db.close()
 
 
 
-
+print("time cost:{} s".format(time.time()-startTime))
 
 
 # t = 1