Commit 8fe70c8c authored by 高雅喆's avatar 高雅喆

bug fix

parent ca5aa2d6
......@@ -279,7 +279,7 @@ object EsmmPredData {
val raw_data2 = sc.sql(
s"""
|select a.device_id,a.city_id,explode(split(a.merge_queue, ',')) as cid_id from raw_data1 a
|select a.device_id,a.city_id as ucity_id,explode(split(a.merge_queue, ',')) as cid_id from raw_data1 a
|left join esmm_train_data b on a.device_id = b.device_id
|where b.device_id is not null
""".stripMargin
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment