@@ -54,7 +54,7 @@ case class JudicialCaseRelation_CaseAgg(s: SparkSession,
sql(
s"""
|INSERT OVERWRITE TABLE winhc_eci_dev.dwd_judicial_case PARTITION(ds,tn)
- |SELECT DENSE_RANK() OVER(PARTITION BY id,tn ORDER BY id) AS id
+ |SELECT DENSE_RANK() OVER(PARTITION BY md5(id,tn) ORDER BY id) AS id
| ,main_case_no
| ,case_no
| ,id AS rowkey