(incubator-paimon) branch master updated: [CDC]Port is not a required parameter in sync pg table. (#2801)

[kerwin]

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

kerwin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 41e9202be [CDC]Port is not a required parameter in sync pg table. 
(#2801)
41e9202be is described below

commit 41e9202be4720f8a29e2448a8bc362cbe2176c71
Author: TaoZex <45089228+tao...@users.noreply.github.com>
AuthorDate: Sat Jan 27 16:23:08 2024 +0800

    [CDC]Port is not a required parameter in sync pg table. (#2801)
---
 .../main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java    | 1 -
 .../org/apache/paimon/flink/action/cdc/postgres/PostgresTypeUtils.java  | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java
 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java
index 2ee417c66..255e1ca7e 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java
@@ -121,7 +121,6 @@ public class SyncJobHandler {
                         cdcSourceConfig,
                         POSTGRES_CONF,
                         PostgresSourceOptions.HOSTNAME,
-                        PostgresSourceOptions.PG_PORT,
                         PostgresSourceOptions.USERNAME,
                         PostgresSourceOptions.PASSWORD,
                         PostgresSourceOptions.DATABASE_NAME,
diff --git 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresTypeUtils.java
 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresTypeUtils.java
index de2a4dcdf..1f3ca3035 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresTypeUtils.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresTypeUtils.java
@@ -81,7 +81,7 @@ public class PostgresTypeUtils {
         }
         precision = precision == null ? 0 : precision;
         scale = scale == null ? 0 : scale;
-        switch (typeName) {
+        switch (typeName.toLowerCase()) {
             case PG_BIT:
             case PG_VARBIT:
                 if (precision <= 1) {