use Array.equals

Signed-off-by: Shivesh Ranjan <[email protected]>
pravega · Jul 31, 2020 · d26043a · d26043a
1 parent bd3b6a9
commit d26043a
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/server/src/main/java/io/pravega/schemaregistry/service/SchemaRegistryService.java b/server/src/main/java/io/pravega/schemaregistry/service/SchemaRegistryService.java
@@ -58,6 +58,7 @@
 import java.math.BigInteger;
 import java.nio.ByteBuffer;
 import java.util.AbstractMap;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
@@ -1003,7 +1004,20 @@ boolean compareNormalized(SchemaInfo schemaInfo) {
             Preconditions.checkNotNull(schemaInfo, "Supply non null Schemainfo.");
             return schemaInfo.getType().equals(normalized.getType()) &&
                     schemaInfo.getSerializationFormat().equals(normalized.getSerializationFormat()) &&
-                    normalizeSchemaBinary(schemaInfo).parsedSchema.equals(this.parsedSchema);
+                    compareParsedSchemas(schemaInfo);
+        }
+
+        private boolean compareParsedSchemas(SchemaInfo schemaInfo) {
+            switch (schemaInfo.getSerializationFormat()) {
+                case Avro:
+                case Protobuf:
+                case Json:
+                    return normalizeSchemaBinary(schemaInfo).parsedSchema.equals(this.parsedSchema);
+                case Any:
+                case Custom:
+                default:
+                    return Arrays.equals(schemaInfo.getSchemaData().array(), this.normalized.getSchemaData().array());
+            }
         }
     }
 }