in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java [198:210]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
SchemaInfo that = ((PulsarSchema<?>) o).getPulsarSchema().getSchemaInfo();
return Objects.equals(schemaInfo.getType(), that.getType())
&& Arrays.equals(schemaInfo.getSchema(), that.getSchema())
&& Objects.equals(schemaInfo.getProperties(), that.getProperties());
}