瀏覽代碼

fix: 增量股权出质

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

+ 2 - 2
src/main/scala/com/winhc/bigdata/spark/jobs/inc_company_equity_info.scala

@@ -66,7 +66,7 @@ object inc_company_equity_info {
            |        ,t1.update_time
            |        ,t1.deleted
            |        from (
-           |SELECT  md5(cleanup(CONCAT_WS('',${dedup.map("tmp." + _)}))) as id
+           |SELECT  md5(cleanup(CONCAT_WS('',${dedup.map("tmp." + _).mkString(",")}))) as id
            |        ,tmp.cid
            |        ,null as cname
            |        ,tmp.base
@@ -91,7 +91,7 @@ object inc_company_equity_info {
            |        ,tmp.deleted
            |FROM    (
            |            SELECT  a.*
-           |                    ,row_number() OVER (PARTITION BY cleanup(CONCAT_WS('',${dedup.map("a." + _)})) ORDER BY update_time DESC) c
+           |                    ,row_number() OVER (PARTITION BY cleanup(CONCAT_WS('',${dedup.map("a." + _).mkString(",")})) ORDER BY update_time DESC) c
            |            FROM    (
            |                        SELECT  *
            |                        FROM    winhc_eci_dev.inc_ods_company_equity_info