in flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java [75:91]
public boolean equals(Object o) {
if (o instanceof InternalJdbcConnectionOptions) {
InternalJdbcConnectionOptions options = (InternalJdbcConnectionOptions) o;
return Objects.equals(url, options.url)
&& Objects.equals(tableName, options.tableName)
&& Objects.equals(driverName, options.driverName)
&& Objects.equals(username, options.username)
&& Objects.equals(password, options.password)
&& Objects.equals(
dialect.getClass().getName(), options.dialect.getClass().getName())
&& Objects.equals(parallelism, options.parallelism)
&& Objects.equals(
connectionCheckTimeoutSeconds, options.connectionCheckTimeoutSeconds);
} else {
return false;
}
}