Commit ba33fc72 by fan.jiang

fix lazada bug

parent eea56463
......@@ -107,11 +107,11 @@ class EtlLazadaActivitionDaily extends CommonSparkJob {
val sql2=
s"""
|select device_id,country
|select lower(device_id) device_id,lower(country) country
|from dwh.ods_dmp_user_info where dt = '${today}' and last_req_day >= '${last_req_day}' and business not in ('other', 'ali_acquisition', 'ali_activation', 'adn_install')
| and device_type='gaid'
| and platform='android'
| group by device_id,country
| group by lower(device_id),lower(country)
""".stripMargin
val dfCache: DataFrame = spark.sql(sql2).persist(StorageLevel.MEMORY_AND_DISK_SER)
......
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