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 6e7d67f [improve](cdc) add mysql set type for type mapping (#297)
6e7d67f is described below
commit 6e7d67f08168d6cc9ca07434c9a2d37587d8653d
Author: wudi <[email protected]>
AuthorDate: Wed Jan 17 14:46:28 2024 +0800
[improve](cdc) add mysql set type for type mapping (#297)
---
.../src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java | 2 ++
1 file changed, 2 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 180414b..704b8b3 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
@@ -82,6 +82,7 @@ public class MysqlType {
private static final String LONGBLOB = "LONGBLOB";
private static final String JSON = "JSON";
private static final String ENUM = "ENUM";
+ private static final String SET = "SET";
public static String toDorisType(String type, Integer length, Integer
scale) {
switch (type.toUpperCase()) {
@@ -164,6 +165,7 @@ public class MysqlType {
case LONGBLOB:
case BINARY:
case VARBINARY:
+ case SET:
return DorisType.STRING;
case JSON:
return DorisType.JSONB;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
