Commit 0bb885e1 by WangJinfeng

update RTDmpFetch poolSize = 50

parent b1dc4d0b
......@@ -195,9 +195,12 @@ class RTDmpMainPre extends CommonSparkJob with Serializable {
// 生成 audienceId -> update_date JSONObject
r._2.foreach(t => {
set.add(t._1)
deviceType = t._2
/*
if (StringUtils.isBlank(deviceType)) {
deviceType = t._2
}
*/
})
(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