fixed ut test

Author: Mrart

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java

@@ -46,6 +46,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Properties;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
@@ -293,4 +294,78 @@ private MetadataConverter[] getMetadataConverters() {
                 .map(TiDBReadableMetadata::getConverter)
                 .toArray(MetadataConverter[]::new);
     }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) {
+            return true;
+        }
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        TiDBTableSource that = (TiDBTableSource) o;
+        return port == that.port
+                && enableParallelRead == that.enableParallelRead
+                && splitSize == that.splitSize
+                && splitMetaGroupSize == that.splitMetaGroupSize
+                && fetchSize == that.fetchSize
+                && connectionPoolSize == that.connectionPoolSize
+                && connectMaxRetries == that.connectMaxRetries
+                && Double.compare(that.distributionFactorUpper, distributionFactorUpper) == 0
+                && Double.compare(that.distributionFactorLower, distributionFactorLower) == 0
+                && physicalSchema.equals(that.physicalSchema)
+                && startupOptions.equals(that.startupOptions)
+                && Objects.equals(tableList, that.tableList)
+                && Objects.equals(tableName, that.tableName)
+                && Objects.equals(connectTimeout, that.connectTimeout)
+                && Objects.equals(jdbcDriver, that.jdbcDriver)
+                && Objects.equals(serverTimeZone, that.serverTimeZone)
+                && Objects.equals(pdAddresses, that.pdAddresses)
+                && Objects.equals(hostMapping, that.hostMapping)
+                && Objects.equals(hostName, that.hostName)
+                && Objects.equals(database, that.database)
+                && Objects.equals(username, that.username)
+                && Objects.equals(password, that.password)
+                && Objects.equals(heartbeatInterval, that.heartbeatInterval)
+                && Objects.equals(chunkKeyColumn, that.chunkKeyColumn)
+                && Objects.equals(chunkKeyColumns, that.chunkKeyColumns)
+                && Objects.equals(jdbcProperties, that.jdbcProperties)
+                && Objects.equals(options, that.options)
+                && Objects.equals(producedDataType, that.producedDataType)
+                && Objects.equals(metadataKeys, that.metadataKeys);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(
+                physicalSchema,
+                startupOptions,
+                tableList,
+                tableName,
+                connectTimeout,
+                jdbcDriver,
+                serverTimeZone,
+                pdAddresses,
+                hostMapping,
+                port,
+                hostName,
+                database,
+                username,
+                password,
+                heartbeatInterval,
+                splitSize,
+                splitMetaGroupSize,
+                fetchSize,
+                connectMaxRetries,
+                connectionPoolSize,
+                distributionFactorUpper,
+                distributionFactorLower,
+                chunkKeyColumn,
+                chunkKeyColumns,
+                jdbcProperties,
+                options,
+                enableParallelRead,
+                producedDataType,
+                metadataKeys);
+    }
 }

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSourceFactoryTest.java

@@ -137,6 +137,10 @@ public void testOptionalProperties() {
         properties.put("port", MY_PORT);
         properties.put("scan.startup.mode", "initial");
         properties.put("heartbeat.interval.ms", "15213ms");
+        properties.put("debezium.tombstones.on.delete", "true");
+        properties.put("debezium.snapshot.mode", "never");
+        properties.put("debezium.offset.flush.interval.ms", "3000");
+        properties.put("debezium.test", "test");
         //        properties.put("server-time-zone", "Asia/Shanghai");
 
         Properties dbzProperties = new Properties();
@@ -156,7 +160,7 @@ public void testOptionalProperties() {
         TiDBTableSource expectedSource =
                 new TiDBTableSource(
                         SCHEMA,
-                        4111,
+                        4000,
                         MY_HOSTNAME,
                         MY_DATABASE,
                         MY_TABLE,
@@ -179,7 +183,7 @@ public void testOptionalProperties() {
                         SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND.defaultValue(),
                         SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND.defaultValue(),
                         null,
-                        null,
+                        new HashMap<>(),
                         JDBC_DRIVER.defaultValue(),
                         StartupOptions.initial());
         Assertions.assertThat(expectedSource).isEqualTo(actualSource);