diff --git a/ingestion/tests/integration/ometa/test_ometa_lineage_api.py b/ingestion/tests/integration/ometa/test_ometa_lineage_api.py
index f0024617554..d17a4869657 100644
--- a/ingestion/tests/integration/ometa/test_ometa_lineage_api.py
+++ b/ingestion/tests/integration/ometa/test_ometa_lineage_api.py
@@ -267,9 +267,9 @@ class OMetaLineageTest(TestCase):
                     columnsLineage=[
                         ColumnLineage(
                             fromColumns=[
-                                f"{self.table1_entity.fullyQualifiedName.root}.name"
+                                f"{self.table1_entity.fullyQualifiedName.root}.another"
                             ],
-                            toColumn=f"{self.table2_entity.fullyQualifiedName.root}.name",
+                            toColumn=f"{self.table2_entity.fullyQualifiedName.root}.another",
                         )
                     ],
                 ),
diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java
index d2b28f2be20..1b6d23fcb5a 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java
@@ -1146,7 +1146,8 @@ public class LineageRepository {
       updated.setUpdatedAt(System.currentTimeMillis());
       updated.setUpdatedBy(updatedBy);
 
-      String detailsJson = JsonUtils.pojoToJson(updated);
+      // Validate Lineage Details
+      String detailsJson = validateLineageDetails(from, to, updated);
       dao.relationshipDAO()
           .insert(fromId, toId, fromEntity, toEntity, Relationship.UPSTREAM.ordinal(), detailsJson);
       addLineageToSearch(from, to, updated);