删除双写

eda/feededa/src/main/scala/com/gmei/EsmmData.scala

@@ -214,10 +214,9 @@ object EsmmData {
              |group by device_id,cid_id
          """.stripMargin
         )
-        union_data_scity_id2.persist()
-        GmeiConfig.writeToJDBCTable("jdbc:mysql://10.66.157.22:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",union_data_scity_id2, table="jerry_test.esmm_train_data",SaveMode.Append)
-        GmeiConfig.writeToJDBCTable("jdbc:mysql://152.136.44.138:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",union_data_scity_id2, table="jerry_test.esmm_train_data",SaveMode.Append)
-        union_data_scity_id2.unpersist()
+
+        GmeiConfig.writeToJDBCTable("jdbc:mysql://152.136.44.138:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",union_data_scity_id2, table="esmm_train_data",SaveMode.Append)
+
       } else {
         println("jerry_test.esmm_train_data already have param.date data")
       }
@@ -595,10 +594,9 @@ object EsmmPredData {
 
       //      union_data_scity_id.createOrReplaceTempView("union_data_scity_id")
       //      println(union_data_scity_id2.count())
-      union_data_scity_id2.persist()
-      GmeiConfig.writeToJDBCTable("jdbc:mysql://10.66.157.22:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",union_data_scity_id2, table="esmm_pre_data",SaveMode.Overwrite)
+
       GmeiConfig.writeToJDBCTable("jdbc:mysql://152.136.44.138:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",union_data_scity_id2, table="esmm_pre_data",SaveMode.Overwrite)
-      union_data_scity_id2.unpersist()
+
 
 
 
@@ -671,7 +669,7 @@ object GetDiaryPortrait {
            |select diary_id,level1_ids,level2_ids,level3_ids,split(level2_ids,",")[0] as level2 from t
          """.stripMargin
       )
-      val jdbc = "jdbc:mysql://10.66.157.22:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true"
+      val jdbc = "jdbc:mysql://152.136.44.138:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true"
 
       GmeiConfig.writeToJDBCTable(jdbc,result,"diary_feat",SaveMode.Overwrite)