From f108c3c1719562e01b666f64dc879a377566e4aa Mon Sep 17 00:00:00 2001 From: Marcus Tang Date: Fri, 23 Aug 2024 17:46:49 +0800 Subject: [PATCH] [Improve](cdc) fix mysql type integer (#476) Co-authored-by: muchun.tang --- .../org/apache/doris/flink/tools/cdc/mysql/MysqlType.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java index 60a5eda25..49afe3751 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java @@ -46,6 +46,9 @@ public class MysqlType { private static final String INT = "INT"; private static final String INT_UNSIGNED = "INT UNSIGNED"; private static final String INT_UNSIGNED_ZEROFILL = "INT UNSIGNED ZEROFILL"; + private static final String INTEGER = "INTEGER"; + private static final String INTEGER_UNSIGNED = "INTEGER UNSIGNED"; + private static final String INTEGER_UNSIGNED_ZEROFILL = "INTEGER UNSIGNED ZEROFILL"; private static final String BIGINT = "BIGINT"; private static final String SERIAL = "SERIAL"; private static final String BIGINT_UNSIGNED = "BIGINT UNSIGNED"; @@ -108,11 +111,14 @@ public static String toDorisType(String type, Integer length, Integer scale) { case SMALLINT_UNSIGNED: case SMALLINT_UNSIGNED_ZEROFILL: case INT: + case INTEGER: case MEDIUMINT: case YEAR: return DorisType.INT; case INT_UNSIGNED: case INT_UNSIGNED_ZEROFILL: + case INTEGER_UNSIGNED: + case INTEGER_UNSIGNED_ZEROFILL: case MEDIUMINT_UNSIGNED: case MEDIUMINT_UNSIGNED_ZEROFILL: case BIGINT: