bug fix

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

@@ -274,8 +274,8 @@ object EsmmPredData {
 
       val raw_data1 = raw_data.rdd.groupBy(_.getAs[String]("device_city")).map {
         case (device_city, cid_data) =>
-          val device_id = device_city.split(",")(0)
-          val city_id = device_city.split(",")(1)
+          val device_id = Try(device_city.split(",")(0)).getOrElse("")
+          val city_id = Try(device_city.split(",")(1)).getOrElse("")
           val cids = Try(cid_data.toSeq.map(_.getAs[String]("similarity_cid").split(",")).flatMap(_.zipWithIndex).sortBy(_._2).map(_._1).distinct.take(300).mkString(",")).getOrElse("")
           (device_id,city_id ,s"$cids")
       }.filter(_._3!="").toDF("device_id","city_id","merge_queue")