diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java
index 4a1236c..a5c8695 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java
@@ -65,7 +65,7 @@ public class RiskRepositoryImpl extends BaseJdbcRepository<RiskEntity, Long> imp
                VALUES (
                    ?, ?::timestamptz, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'N'
                )
-               ON CONFLICT (lrno)
+               ON CONFLICT (lrno, lastupdated)
                DO UPDATE SET
                    riskdatamaintained = EXCLUDED.riskdatamaintained,
                    dayssincelastseenonais = EXCLUDED.dayssincelastseenonais,
diff --git a/src/main/java/com/snp/batch/jobs/sanction/batch/repository/ComplianceRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/sanction/batch/repository/ComplianceRepositoryImpl.java
index 981e081..db90923 100644
--- a/src/main/java/com/snp/batch/jobs/sanction/batch/repository/ComplianceRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/sanction/batch/repository/ComplianceRepositoryImpl.java
@@ -58,7 +58,7 @@ public class ComplianceRepositoryImpl extends BaseJdbcRepository<ComplianceEntit
                   VALUES (
                       ?, ?::timestamptz, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'N'
                   )
-                  ON CONFLICT (lrimoshipno)
+                  ON CONFLICT (lrimoshipno, dateamended)
                   DO UPDATE SET
                       legaloverall = EXCLUDED.legaloverall,
                       shipbessanctionlist = EXCLUDED.shipbessanctionlist,