[mysql] Add heartbeatInterval field to equals() and hashCode() (#1118)

3 years ago · c06fd64c50
parent b7e6ccc67d
commit c06fd64c50
1 changed files with 4 additions and 2 deletions
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/table/MySqlTableSource.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/table/MySqlTableSource.java
@ -360,7 +360,8 @@ public class MySqlTableSource implements ScanTableSource, SupportsReadingMetadat
                && Objects.equals(startupOptions, that.startupOptions)
                && Objects.equals(producedDataType, that.producedDataType)
                && Objects.equals(metadataKeys, that.metadataKeys)
-                && Objects.equals(jdbcProperties, that.jdbcProperties);
+                && Objects.equals(jdbcProperties, that.jdbcProperties)
+                && Objects.equals(heartbeatInterval, that.heartbeatInterval);
    }

    @Override
@ -389,7 +390,8 @@ public class MySqlTableSource implements ScanTableSource, SupportsReadingMetadat
                producedDataType,
                metadataKeys,
                scanNewlyAddedTableEnabled,
-                jdbcProperties);
+                jdbcProperties,
+                heartbeatInterval);
    }

    @Override