yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-13 17:32:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: Bug when updating a topic with missing message schema (#9940)

Browse Source
This commit is contained in:
Nahuel 2023-01-26 20:23:14 +01:00 committed by GitHub
parent 4c91e80132
commit ed062c62d6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -242,15 +242,15 @@ public class TopicRepository extends EntityRepository<Topic> {
if (updated.getMessageSchema() != null) { if (updated.getMessageSchema() != null) {
recordChange( recordChange(
"messageSchema.schemaText", "messageSchema.schemaText",
original.getMessageSchema().getSchemaText(), original.getMessageSchema() == null ? null : original.getMessageSchema().getSchemaText(),
updated.getMessageSchema().getSchemaText()); updated.getMessageSchema().getSchemaText());
recordChange( recordChange(
"messageSchema.schemaType", "messageSchema.schemaType",
original.getMessageSchema().getSchemaType(), original.getMessageSchema() == null ? null : original.getMessageSchema().getSchemaType(),
updated.getMessageSchema().getSchemaType()); updated.getMessageSchema().getSchemaType());
updateSchemaFields( updateSchemaFields(
"messageSchema.schemaFields", "messageSchema.schemaFields",
original.getMessageSchema().getSchemaFields(), original.getMessageSchema() == null ? null : original.getMessageSchema().getSchemaFields(),
updated.getMessageSchema().getSchemaFields(), updated.getMessageSchema().getSchemaFields(),
EntityUtil.schemaFieldMatch); EntityUtil.schemaFieldMatch);
} }