init id_mapping

src/main/scala/mobvista/dmp/datasource/id_mapping/IDMappingGraphx.scala

@@ -91,7 +91,7 @@ class IDMappingGraphx extends CommonSparkJob with Serializable {
     }), schema = schame)
 
     val vertex = todayDF.rdd.map(row => {
-      processVertex(date, row, idSet.toArray, idMainSet)
+      processVertex(date, row, idSet, idMainSet)
     }).flatMap(l => l)
 
     val maxGraph = vertex.combineByKey(
@@ -265,8 +265,8 @@ class IDMappingGraphx extends CommonSparkJob with Serializable {
     val array = new ArrayBuffer[(String, JSONObject, String)]()
     val iters = kv._2
     val oneID = new JSONObject()
-    iters.foreach(kv => {
-      oneID.put(kv._1, kv._2)
+    iters.foreach(ir => {
+      oneID.put(ir._1, ir._2)
     })
     iters.filter(tp => {
       !mainIDSet.contains(tp._2.getString("id_type"))