in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java [77:92]
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(
dialect.getClass().getName(), options.dialect.getClass().getName())
&& Objects.equals(parallelism, options.parallelism)
&& Objects.equals(
connectionCheckTimeoutSeconds, options.connectionCheckTimeoutSeconds)
&& Objects.equals(properties, options.properties);
} else {
return false;
}
}