Skip to content

Commit 2466b2b

Browse files
authored
[Fix](cdc) Fix the problem of converting the int2 and smallserial data types of the pg (#582)
1 parent be72511 commit 2466b2b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public static String toDorisType(String postgresType, Integer precision, Integer
7575
switch (postgresType) {
7676
case INT2:
7777
case SMALLSERIAL:
78-
return DorisType.TINYINT;
78+
return DorisType.SMALLINT;
7979
case INT4:
8080
case SERIAL:
8181
return DorisType.INT;

0 commit comments

Comments
 (0)