You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by di...@apache.org on 2025/04/01 10:49:38 UTC

(doris-flink-connector) branch master updated: [Fix](cdc) Fix the problem of converting the int2 and smallserial data types of the pg (#582)

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2466b2b5 [Fix](cdc) Fix the problem of converting the int2 and smallserial data types of the pg (#582)
2466b2b5 is described below

commit 2466b2b5db789d8f108fcba1dddee681cdb4e1b8
Author: Aalron <48...@users.noreply.github.com>
AuthorDate: Tue Apr 1 18:49:32 2025 +0800

    [Fix](cdc) Fix the problem of converting the int2 and smallserial data types of the pg (#582)
---
 .../java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java
index ed80d45e..ddffb6d9 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java
@@ -75,7 +75,7 @@ public class PostgresType {
         switch (postgresType) {
             case INT2:
             case SMALLSERIAL:
-                return DorisType.TINYINT;
+                return DorisType.SMALLINT;
             case INT4:
             case SERIAL:
                 return DorisType.INT;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org