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 ae6c6c8..dee3f49 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, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
                )
-               ON CONFLICT (lrno, lastupdated)
+               ON CONFLICT (lrno)
                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 378f872..0f97233 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, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
                   )
-                  ON CONFLICT (lrimoshipno, dateamended)
+                  ON CONFLICT (lrimoshipno)
                   DO UPDATE SET
                       legaloverall = EXCLUDED.legaloverall,
                       shipbessanctionlist = EXCLUDED.shipbessanctionlist,