[rocketmq-schema-registry] branch main updated: [ISSUE #79] Fix CachedschemaRegistryClient.deleteSchema execution failed

[zhoubo]

This is an automated email from the ASF dual-hosted git repository.

zhoubo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-schema-registry.git


The following commit(s) were added to refs/heads/main by this push:
     new 30f697e  [ISSUE #79] Fix CachedschemaRegistryClient.deleteSchema 
execution failed
30f697e is described below

commit 30f697e9aa66b5aadb8169ce2936b3b6f816a127
Author: Xiaojian Sun <sunxiaojian...@163.com>
AuthorDate: Fri Apr 21 10:15:48 2023 +0800

    [ISSUE #79] Fix CachedschemaRegistryClient.deleteSchema execution failed
    
    Co-authored-by: xiaoyi <xiaojian....@alibaba-inc.com>
---
 .../rocketmq/schema/registry/client/CachedSchemaRegistryClient.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
 
b/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
index 8e87666..d884492 100644
--- 
a/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
+++ 
b/client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java
@@ -131,7 +131,10 @@ public class CachedSchemaRegistryClient implements 
SchemaRegistryClient {
         String subjectFullName = String.format("%s/%s/%s", cluster, tenant, 
subject);
         schemaCacheBySubject.invalidate(subjectFullName);
         schemaCacheBySubjectAndVersion.invalidate(new 
SubjectAndVersion(cluster, tenant, subject, version));
-        subjectToVersion.get(subjectFullName).remove(version);
+
+        if (subjectToSchema.get(subjectFullName) != null) {
+            subjectToVersion.get(subjectFullName).remove(version);
+        }
 
         return restService.deleteSchema(cluster, tenant, subject, version);
     }