Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5564#discussion_r170224845
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSource.java
---
@@ -83,10 +84,32 @@ protected JsonRowDeserializationSchema
getDeserializationSchema() {
@Override
public String explainSource() {
- return "KafkaJSONTableSource";
+ return "KafkaJsonTableSource";
}
- //////// SETTERS FOR OPTIONAL PARAMETERS
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (!(o instanceof KafkaJsonTableSource)) {
+ return false;
+ }
+ if (!super.equals(o)) {
+ return false;
+ }
+ KafkaJsonTableSource that = (KafkaJsonTableSource) o;
+ return failOnMissingField == that.failOnMissingField &&
+ Objects.equals(jsonSchema, that.jsonSchema) &&
+ Objects.equals(fieldMapping, that.fieldMapping);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(super.hashCode(), jsonSchema, fieldMapping,
failOnMissingField);
--- End diff --
`TableSchema` does not override `hashCode()`
---
