[minor][cdc-connector][postgres] PostgresDialect removes useless code

This closes #3416.
pull/3481/head
ChengJie1053 7 months ago committed by GitHub
parent 94a0415475
commit 2d50e43137
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -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;

@ -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);
}

Loading…
Cancel
Save