xufei 4 년 전
부모
커밋
9e1dab32bc
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/utils/CompanyIncrForCidsUtils.scala

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/utils/CompanyIncrForCidsUtils.scala

@@ -188,7 +188,7 @@ case class CompanyIncrForCidsUtils(s: SparkSession,
          |INSERT OVERWRITE TABLE  $inc_ads_company_tb PARTITION(ds='$lastDsIncOds')
          |SELECT  ${subRes.mkString(",")}
          |FROM    (
-         |            SELECT  $split_cols,${sublistTableFieldName.mkString(",")}
+         |            SELECT  $split_cols,${columns.mkString(",")}
          |                    ,ROW_NUMBER() OVER (PARTITION BY id ORDER BY update_time DESC ) num
          |                    ,md5(cleanup(CONCAT_WS('',${cols_md5.mkString(",")}))) AS rowkey
          |            FROM    ${inc_ods_company_tb}