[hotfix][postgres] PostgresSourceFetchTaskContext log do not output PostgresConnectorConfig

2 weeks ago · 0ae0743859
parent c6cf46b75c
commit 0ae0743859
1 changed files with 1 additions and 1 deletions
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java
@ -152,7 +152,7 @@ public class PostgresSourceFetchTaskContext extends JdbcSourceFetchTaskContext {
                                    .build());
        }

-        LOG.info("PostgresConnectorConfig is ", dbzConfig.getConfig().asProperties().toString());
+        LOG.info("PostgresConnectorConfig is {}", dbzConfig.getConfig().asProperties().toString());
        setDbzConnectorConfig(dbzConfig);
        PostgresConnectorConfig.SnapshotMode snapshotMode =
                PostgresConnectorConfig.SnapshotMode.parse(