ISSUE-653 : Fix NPE while deleting schema metadata with no schema ve…

…rsions (#654)
hortonworks · Oct 21, 2020 · 6ce5918 · 6ce5918
1 parent 2ee72ba
commit 6ce5918
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...y/core/src/main/java/com/hortonworks/registries/schemaregistry/DefaultSchemaRegistry.java b/...y/core/src/main/java/com/hortonworks/registries/schemaregistry/DefaultSchemaRegistry.java
@@ -308,7 +308,8 @@ public void deleteSchema(String schemaName) throws SchemaNotFoundException {
             }
         }
         // Remove all serdes mappings for this schema name
-        Collection<SchemaSerDesMapping> schemaSerDesMappings = getSchemaSerDesMappings(schemaMetadataId);
+        SchemaMetadataInfo schemaMetadataInfo = getSchemaMetadataInfo(schemaName);
+        Collection<SchemaSerDesMapping> schemaSerDesMappings = getSchemaSerDesMappings(schemaMetadataInfo.getId());
         if (schemaSerDesMappings != null) {
             for (SchemaSerDesMapping schemaSerDesMapping: schemaSerDesMappings) {
                 storageManager.remove(schemaSerDesMapping.getStorableKey());