Skip to content

M
mobvista-dmp
Commit 275b71e0 by WangJinfeng
Options

fix RTDmpMainPre

parent 0bb885e1
Showing with 0 additions and 3 deletions
src/main/scala/mobvista/dmp/datasource/rtdmp/RTDmpMainPre.scala
...@@ -195,12 +195,9 @@ class RTDmpMainPre extends CommonSparkJob with Serializable { ...@@ -195,12 +195,9 @@ class RTDmpMainPre extends CommonSparkJob with Serializable {
// 生成 audienceId -> update_date JSONObject // 生成 audienceId -> update_date JSONObject
r._2.foreach(t => { r._2.foreach(t => {
set.add(t._1) set.add(t._1)
deviceType = t._2
/*
if (StringUtils.isBlank(deviceType)) { if (StringUtils.isBlank(deviceType)) {
deviceType = t._2 deviceType = t._2
} }
*/
}) })
(devId, set, deviceType) (devId, set, deviceType)
}) })
......
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