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 f108c3c1 [Improve](cdc) fix mysql type integer (#476)
f108c3c1 is described below
commit f108c3c1719562e01b666f64dc879a377566e4aa
Author: Marcus Tang <[email protected]>
AuthorDate: Fri Aug 23 17:46:49 2024 +0800
[Improve](cdc) fix mysql type integer (#476)
Co-authored-by: muchun.tang <[email protected]>
---
.../main/java/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 60a5eda2..49afe375 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 class MysqlType {
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:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
