xufei 4 yıl önce
ebeveyn
işleme
3db8a54ef0

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPreNew.scala

@@ -222,8 +222,8 @@ case class JudicialCaseRelationPreNew(s: SparkSession, project: String, ds: Stri
          |            ,concat_ws('',case_stage(case_no)) as case_stage
          |            ,replace_char(plaintiff) as yg_name
          |            ,replace_char(defendant) as bg_name
+         |            ,start_date as date
          |            ,md5(cleanup(CONCAT_WS('',case_no,start_date))) as detail_id
-         |            ,rowkey as detail_id
          |            ,0.0 as case_amt
          |      from $project.ads_company_court_open_announcement
          |      where length(case_no) > 0 and ds > '0'