yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-30 03:46:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Schema Field Null Issue (#16510)

Browse Source
This commit is contained in:
Mohit Yadav 2024-06-03 13:03:26 +05:30 committed by GitHub
parent 5a457d37fe
commit 022772943f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TopicRepository.java
View File

@ -410,9 +410,9 @@ public class TopicRepository extends EntityRepository<Topic> {
updateSchemaFields( updateSchemaFields(
"messageSchema.schemaFields", "messageSchema.schemaFields",
original.getMessageSchema() == null original.getMessageSchema() == null
? null ? new ArrayList<>()
: original.getMessageSchema().getSchemaFields(), : listOrEmpty(original.getMessageSchema().getSchemaFields()),
updated.getMessageSchema().getSchemaFields(), listOrEmpty(updated.getMessageSchema().getSchemaFields()),
EntityUtil.schemaFieldMatch); EntityUtil.schemaFieldMatch);
} }
recordChange("topicConfig", original.getTopicConfig(), updated.getTopicConfig()); recordChange("topicConfig", original.getTopicConfig(), updated.getTopicConfig());
@ -489,7 +489,10 @@ public class TopicRepository extends EntityRepository<Topic> {
if (updated.getChildren() != null && stored.getChildren() != null) { if (updated.getChildren() != null && stored.getChildren() != null) {
String childrenFieldName = EntityUtil.getFieldName(fieldName, updated.getName()); String childrenFieldName = EntityUtil.getFieldName(fieldName, updated.getName());
updateSchemaFields( updateSchemaFields(
childrenFieldName, stored.getChildren(), updated.getChildren(), fieldMatch); childrenFieldName,
listOrEmpty(stored.getChildren()),
listOrEmpty(updated.getChildren()),
fieldMatch);
} }
} }