소스 검색

fix: 查失信公司

许家凯 4 년 전
부모
커밋
a88282c1fc
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

@@ -363,7 +363,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_company