in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java [269:280]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
AuthRestClientFactory that = (AuthRestClientFactory) o;
return Objects.equals(pathPrefix, that.pathPrefix)
&& Objects.equals(username, that.username)
&& Objects.equals(password, that.password);
}