Skip to content

Commit a9f1320

Browse files
rakhiagrRakhi Agrawal
andauthored
Added check null for extracted json value for column value (#500)
Co-authored-by: Rakhi Agrawal <rakagrawal@linkedin.com>
1 parent 489394c commit a9f1320

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

dao-impl/ebean-dao/src/main/java/com/linkedin/metadata/dao/EbeanLocalRelationshipQueryDAO.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -374,9 +374,12 @@ private <SNAPSHOT extends RecordTemplate> SNAPSHOT constructSnapshot(@Nonnull fi
374374
String auditedAspectStr = sqlRow.getString(colName);
375375

376376
if (auditedAspectStr != null) {
377-
RecordTemplate aspect = RecordUtils.toRecordTemplate(ClassUtils.loadClass(aspectCanonicalName),
378-
EBeanDAOUtils.extractAspectJsonString(auditedAspectStr));
379-
aspects.add(ModelUtils.newAspectUnion(ModelUtils.getUnionClassFromSnapshot(snapshotClass), aspect));
377+
String extractedAspectStr = EBeanDAOUtils.extractAspectJsonString(auditedAspectStr);
378+
if (extractedAspectStr != null) {
379+
RecordTemplate aspect = RecordUtils.toRecordTemplate(ClassUtils.loadClass(aspectCanonicalName),
380+
extractedAspectStr);
381+
aspects.add(ModelUtils.newAspectUnion(ModelUtils.getUnionClassFromSnapshot(snapshotClass), aspect));
382+
}
380383
}
381384
}
382385

0 commit comments

Comments
 (0)