(flink-cdc) branch master updated: [minor][cdc-connector][postgres] PostgresDialect removes useless code

[leonard]

This is an automated email from the ASF dual-hosted git repository.

leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 2d50e4313 [minor][cdc-connector][postgres] PostgresDialect removes 
useless code
2d50e4313 is described below

commit 2d50e43137b32ace0ddec3d09bb75fa62e09d71a
Author: ChengJie1053 <18033291...@163.com>
AuthorDate: Wed Jul 17 17:30:53 2024 +0800

    [minor][cdc-connector][postgres] PostgresDialect removes useless code
    
    This closes #3416.
---
 .../cdc/connectors/base/source/assigner/StreamSplitAssigner.java      | 4 ----
 .../apache/flink/cdc/connectors/postgres/source/PostgresDialect.java  | 4 +---
 2 files changed, 1 insertion(+), 7 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java
index b30652877..74bd04fca 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java
@@ -28,9 +28,6 @@ import 
org.apache.flink.cdc.connectors.base.source.meta.split.FinishedSnapshotSp
 import org.apache.flink.cdc.connectors.base.source.meta.split.SourceSplitBase;
 import org.apache.flink.cdc.connectors.base.source.meta.split.StreamSplit;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
@@ -42,7 +39,6 @@ import java.util.Optional;
 /** Assigner for stream split. */
 public class StreamSplitAssigner implements SplitAssigner {
 
-    private static final Logger LOG = 
LoggerFactory.getLogger(StreamSplitAssigner.class);
     private static final String STREAM_SPLIT_ID = "stream-split";
 
     private final SourceConfig sourceConfig;
diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java
index 25a5186d1..2d17a1c52 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java
@@ -159,9 +159,7 @@ public class PostgresDialect implements 
JdbcDataSourceDialect {
         try (JdbcConnection jdbc = openJdbcConnection(sourceConfig)) {
             return TableDiscoveryUtils.listTables(
                     // there is always a single database provided
-                    sourceConfig.getDatabaseList().get(0),
-                    jdbc,
-                    ((PostgresSourceConfig) sourceConfig).getTableFilters());
+                    sourceConfig.getDatabaseList().get(0), jdbc, 
sourceConfig.getTableFilters());
         } catch (SQLException e) {
             throw new FlinkRuntimeException("Error to discover tables: " + 
e.getMessage(), e);
         }