From 9c905f6dd12e3885f08362110eb0197e8cf7689c Mon Sep 17 00:00:00 2001
From: Qingsheng Ren <renqschn@gmail.com>
Date: Tue, 26 Apr 2022 10:11:14 +0800
Subject: [PATCH] [mysql] Add heartbeatInterval field to equals() and
 hashCode() (#1116)

---
 .../cdc/connectors/mysql/table/MySqlTableSource.java        | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 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
index de46707f8..b0f5ae8ee 100644
--- 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