瀏覽代碼

fix: 解决查老赖不同表之间rowkey有冲突

许家凯 4 年之前
父節點
當前提交
59e8d0101f
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/deadbeat/deadbeat_info.scala

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/deadbeat/deadbeat_info.scala

@@ -252,7 +252,7 @@ case class deadbeat_info(s: SparkSession,
          |SELECT  *
          |FROM    (
          |            SELECT  *
-         |                    ,ROW_NUMBER() OVER(PARTITION BY rowkey ORDER BY ds DESC ) AS num
+         |                    ,ROW_NUMBER() OVER(PARTITION BY rowkey,tn ORDER BY ds DESC ) AS num
          |            FROM    (
          |                        SELECT  *
          |                        FROM    winhc_eci_dev.ads_deadbeat_person