add esmm_pre

tensnsorflow/test.py

@@ -20,7 +20,7 @@ def esmm_pre():
     yesterday = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y-%m-%d")
     print(yesterday)
     conf = SparkConf().setAppName("esmm_pre").set("spark.io.compression.codec", "lzf")
-    spark = SparkSession.builder.getOrCreate(conf)
+    spark = SparkSession.builder.conf(conf).getOrCreate()
     spark.sql("""
     select concat(tmp1.device_id,",",tmp1.city_id) as device_city, tmp1.merge_queue from (select device_id,if(city_id='world','worldwide',city_id) city_id,similarity_cid as merge_queue from nd_device_cid_similarity_matrix
 union select device_id,if(city_id='world','worldwide',city_id) city_id,native_queue as merge_queue from ffm_diary_queue